Функция Azure - EventHub Триггер Py Функция - PullRequest
Новая
       9

Функция Azure - EventHub Триггер Py Функция

0 голосов
/ 18 февраля 2019

Я создал Azure Func концентратора события в Python, я не могу прочитать сообщение о событии с помощью приведенного ниже кода, 

import logging
import azure.functions as func

def main(event: func.EventHubEvent):
    logging.info('Event Hubs trigger function processed message: ', event.get_body())
    logging.info('  EnqueuedTimeUtc =', event.enqueued_time)
    logging.info('  SequenceNumber =', event.sequence_number)
    logging.info('  Offset =', event.offset)

Как вызвать основную функцию, которая имеет параметр?Пожалуйста, помогите об этом !!

Я также пытался создать объект, но так как это модуль абстрактного класса, я получаю сообщение об ошибке 

def main(event):

print(event)

e = event()

print('Event Hubs trigger function processed message: ', e.get_body())

И ошибка: 

main(func.EventHubEvent)
Microsoft.Azure.WebJobs.Script: Traceback (most recent call last): File 
"D:\home\site\wwwroot\CDPConversion\run.py",
line 92, in <module> main(func.EventHubEvent) File 
"D:\home\site\wwwroot\CDPConversion\run.py", line 85, in main e = 
event() TypeError: Can't instantiate abstract class EventHubEvent with 
abstract methods enqueued_time, get_body, offset, partition_key, sequence_number

Пожалуйста, предоставьте решение для чтения сообщений / событий из eventhub.

1 Ответ

0 голосов
/ 19 февраля 2019

Jay,

Ваш класс должен определить реализацию get_body и других ';это абстрактный метод, и конкретные подклассы должны его реализовывать.

Проверьте этот поток для дальнейшего объяснения:

«Не могу создать экземпляр абстрактного класса… с абстрактными методами» в классе, который не долженУ меня нет абстрактного метода

Надеюсь, это поможет.

...