Можете ли вы использовать сообщение из EventHub и проверить его, не используя интерфейс EventProcessorHost? - PullRequest
0 голосов
/ 19 сентября 2019

Я пытаюсь использовать события из моего EventHub, и пока я делаю это, я бы хотел проверить это событие.В настоящее время единственный способ добиться этого - установить контрольную точку через EventProcessorHost.Тем не менее, в моей ситуации это перебор, и мне было интересно, есть ли интерфейс или другой способ проверки события?

def eh_read_single_message(eh_params: EventHubParmas, partition: str):
    OFFSET = Offset("-1")

    logger = logging.getLogger(__name__)

    try:
        client = EventHubClient(address=eh_params.address, username=eh_params.user, 
        password=eh_params.key, debug=False)
        logger.debug('Reading from the eventhub %s', eh_params.eventhub)
        receiver = client.add_receiver(
            consumer_group=eh_params.consumer_group, partition=partition, prefetch=5000, 
            offset=OFFSET)
        client.run()
        return receiver.receive(max_batch_size= 1, timeout=100)
        #for example checkpoint()
    except:
        logger.exception('Failed to read from the eventhub %s', eh_params.eventhub)
    finally:
        client.stop()
        logger.debug('Successfully read from the eventhub %s', eh_params.eventhub)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...