顾名思义,我希望在Power BI中看到实时数据。我已经建立了到火花流的管道,在那里我正在处理数据,现在我想要推入Power BI。并且最好使用Python。
现在,根据我的理解,可能会有不同的方法,如下所述。
我的目标是拥有最小的延迟。
任何帮助都将不胜感激。
发布于 2018-06-08 05:39:44
这可能不是最好的方法。我认为最好的方法是编写您自己的structured streaming integration。但是,您可以使用PubNub。下面是一些用于在PubNub通道上发布仪表板数据的Python代码。
import requests
def publishRecord(record):
requests.get('http://pubsub.pubnub.com/publish/publish_key_here/subscribe_key_here/0/pubnub_channel_name/0/' + str(record))
rdd.foreach(publishRecord)
您可以使用TypeScript在您的仪表板中订阅同一频道。
https://stackoverflow.com/questions/50713894
复制相似问题