Я отправляю дамп JSON в концентратор событий, используя мое приложение python. Моя строка подключения имеет вид
connection_string = "Конечная точка = sb: //xyz.servicebus.windows.net/; SharedAccessKeyName = abc; SharedAccessKey = pqr"
Я получаю следующий ответ
Токен с полным результатом: 0, статус: 202, описание: b'Accepted, соединение: xxxxxxxxx
Но я не вижу данных в eventhub. Я тоже не получаю никакой ошибки. Мой вопрос - это событие отправляется? Если событие успешно отправлено, не должны ли мы получить код ответа 200?
Мой код взят из этой ссылки
from azure.eventhub import EventHubProducerClient, EventData
def send_event_data_batch(producer, data):
# Without specifying partition_id or partition_key
# the events will be distributed to available partitions via round-robin.
event_data_batch = producer.create_batch()
event_data_batch.add(EventData(data))
try:
producer.send_batch(event_data_batch)
except Exception as exp:
_LOG.info(type(exp).__name__)
_LOG.info(exp.args)
producer.close()
def send_data_to_event_hub(data):
producer = EventHubProducerClient.from_connection_string(
conn_str=connection_string,
eventhub_name="EVENT HUB NAME" )
with producer:
send_event_data_batch(producer, data)
producer.close()