Как отправить сообщение в концентратор событий через python

Question

Я пытаюсь подключить множество объектов iot к концентратору событий и сохранить их в хранилище больших двоичных объектов (также в базе данных sql). Я хочу сделать это с Python (и я не уверен, если это рекомендуемая практика). Документация по питону сбивала с толку. Я попробовал несколько примеров, но они создают запись в хранилище BLOB-объектов, но записи, похоже, не имеют значения.

Вещи как это: Objavro.codecnullavro.schema \ EC { "типа": "запись", "имя": "пространство имена" "EventData": "Microsoft.ServiceBus.Messaging", "поле": [{ "Имя": "SequenceNumber", "Тип": "длинный"} ...

это не то, что я посылаю. Как я могу решить это?

Answer 1

Это формат строки подключения для вставки новых сообщений в eventhub с использованием kafka-python. Если вы использовали 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 = "Конечная точка = SB: // {your_eventhub} .servicebus.windows.net /; SharedAccessKeyName = RootSendAccessKey; SharedAccessKey = {youraccesskey}"

Вы можете найти KAFKA_HOST и KAFKA_ENDPOING на консоли Azure.