Я пытаюсь использовать события из моего 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)