如何通过python将消息发送到事件中心

Question

我试图将许多iot对象连接到eventhub并将它们保存到blob存储（也是一个sql数据库）。我想用python做这个（我不确定这是否是推荐的做法）。有关python的文档令人困惑。我尝试了一些例子，但是他们创建了blob存储的条目，但条目似乎无关紧要。

这样的事情：Objavro.codecnullavro.schema \ EC {“type”：“record”，“name”：“EventData”，“namespace”：“Microsoft.ServiceBus.Messaging”，“fields”：[{“name”： “的SequenceNumber”， “类型”： “长”} ...

这不是我发送的。我怎么解决这个问题？

Answer 1

这是使用kafka-python在eventhub中插入新消息的连接字符串格式。如果您使用kafka并想要替换，则只需更改此连接字符串即可。

import ssl
context = ssl.create_default_context()
context.options &= ssl.OP_NO_TLSv1
context.options &= ssl.OP_NO_TLSv1_1

self.kafka = KafkaProducer(bootstrap_servers=KAFKA_HOST,connections_max_idle_ms=5400000,security_protocol='SASL_SSL',value_serializer=lambda v: json.dumps(v).encode('utf-8'),sasl_mechanism='PLAIN',sasl_plain_username='$ConnectionString',sasl_plain_password={YOUR_KAFKA_ENDPOINT},api_version = (0,10),retries=5,ssl_context = context)

KAFKA_HOST =“{your_eventhub} .servicebus.windows.net：9093”KAFKA_ENDPOINT =“Endpoint = sb：// {your_eventhub} .servicebus.windows.net /; SharedAccessKeyName = RootSendAccessKey; SharedAccessKey = {youraccesskey}”

您可以从Azure控制台中找到KAFKA_HOST和KAFKA_ENDPOING。