Power BI 实现实时更新Streaming Dataset

一、在PowerBI portal端需要准备的操作：

1. https://app.powerbi.cn 登陆，点击左侧My Workspace，你需要有一个账号

2. 选入Datasets，点击页面右上角的Creat,添加Streaming dataset

3.添加API{ }

4.记录Push URL , 这个后续作为post data的URL

二、在c#代码中的操作：

1. realTimePushURL 改成上文你的Push URL
2. 一定要注意数据结构 那个postData变量的结构要和streaming dataset的结构一致

   using System;
   using System.Collections.Generic;
   using System.Linq;
   using System.Net;
   using System.Text;
   using System.Threading.Tasks;
   using System.IO;
    
   namespace StreamDataToPowerBI
   {
       class Program
       {
           // 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 = new Random();
                       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 = new StreamReader(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);
               }
           }
       }
   }

三、在portal中设置展示结果,大致实现过程：

1. 先创建一个dashboard

2. 点击右上角的Add tile

3. 选定我们的streaming data tile 

4. 执行相应的添加即可

5.实时展示结果：（实时更新显示C#代码发来的random数据）