python - 如何使用 Python SDK 将变量发送到 Azure 事件中心

标签 python azure azure-eventhub

如果我有一个包含温度值的变量,如何使用 ServiceBusService.send_event 发送它?

最佳答案

这取决于您在事件中心的另一端如何使用它。如果您使用Azure Stream Analytics您必须确保发送到事件中心的格式是 json、csv 或 arvo

如果你有一个变量,创建一个字典,使用 Python 的 json library 序列化它就足够简单了。并发送结果字符串。示例:

from azure.servicebus.control_client import ServiceBusService
import json;

sbs = ServiceBusService("your_namespace",
                        shared_access_key_name="your_policy_name",
                        shared_access_key_value="your_policy_secret")

# build dictionary and send value
temp = {'DeviceId': 'dev-01', 'Temperature': str(i)}
sbs.send_event('woodstove2', json.dumps(temp))

关于python - 如何使用 Python SDK 将变量发送到 Azure 事件中心,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32148503/

相关文章:

azure - 使用 Azure 事件中心的 Spark Streaming

python - Logparser 2.2 和 regex/sql

javascript - 使用 Python 从站点(部分用 Javascript 编写)下载文件

Azure 通信服务 - 预先创建指定日期和时间的视频 session 并记录链接

azure - 搜索 Azure 文件共享

c# - 我们是否应该将 Microsoft.Azure.EventHubs.Processor 库与 .NET 框架一起使用

python - python可以读取这种类型的配置文件吗?

python - 类型错误 : argument of type 'PosixPath' is not iterable

azure - 从客户端获取redis azure缓存的最大内存

azure - 将分析流式传输到事件中心 - 意外串联事件