usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Net;usingSystem.Text;usingSystem.Threading.Tasks;usingSystem.IO;namespaceStreamDataToPowerBI

{classProgram

{//Paste your own push URL below//e.g.https://api.powerbi.com/beta/2b958e42-b81e-441d-af13-801621ce8401/datasets/a5a15fd1-8cb6-4527-b2e6-f22f2a274d4d/rows?key=apsBX1ef%2F8a7ToL2xxxxxxxxxxxZeGATSyRYerZKpnu%2FbE2g2yDM0%2Bs4cDW9mqu5zKoGcQ27vJuh0Huw%3D%3D

private static string realTimePushURL = "** paste your push URL here **";static void Main(string[] args)

{while (true) {try{//Declare values that we're about to send

String currentTime = DateTime.UtcNow.ToString("yyyy-MM-ddTHH:mm:ss.fffZ"); //2017-11-03T06:23:35.521Z

Random r = newRandom();int currentValue = r.Next(0, 100);//Send POST request to the push URL//Uses the WebRequest sample code as documented here:https://msdn.microsoft.com/en-us/library/debx8sh9(v=vs.110).aspx

WebRequest request = WebRequest.Create(this.PostUri);

request.Method= "POST";string postData = String.Format("[{{ \"time\": \"{0}\", \"value\": {1}}}]", currentTime, currentValue);

Console.WriteLine(String.Format("Making POST request with data: {0}", postData));//Prepare request for sending

byte[] byteArray =Encoding.UTF8.GetBytes(postData);

request.ContentLength=byteArray.Length;//Get the request stream.

Stream dataStream =request.GetRequestStream();//Write the data to the request stream.

dataStream.Write(byteArray, 0, byteArray.Length);//Close the Stream object.

dataStream.Close();//Get the response.

WebResponse response =request.GetResponse();//Display the status.

Console.WriteLine(String.Format("Service response: {0}", ((HttpWebResponse)response).StatusCode));//Get the stream containing content returned by the server.

dataStream =response.GetResponseStream();//Open the stream using a StreamReader for easy access.

StreamReader reader = newStreamReader(dataStream);//Read the content.

string responseFromServer =reader.ReadToEnd();//Display the content.

Console.WriteLine(responseFromServer);//Clean up the streams.

reader.Close();

dataStream.Close();

response.Close();

}catch(Exception ex)

{

Console.WriteLine(ex);

}//Wait 1 second before sending

System.Threading.Thread.Sleep(1000);

}

}

}

}

Logo

一站式 AI 云服务平台

更多推荐