Отправка данных в azure концентратор событий с помощью приложения python - PullRequest
0 голосов
/ 01 апреля 2020

Я отправляю дамп 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()

1 Ответ

0 голосов
/ 06 апреля 2020

Метод send () ничего не возвращает (None), если он успешен, или выдает ошибку семейства EventHubError, если он не успешен. «Токен, заполненный с результатом: 0, статус: 202, описание: b'Accepted ', connection: xxxxxxxxx» регистрирует информацию о создании соединений.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...