Функция Azure не получает события Eventhub

Я начал играть с функциями Azure и столкнулся с проблемой, что моя функция не запускается событиями, входящими в мой концентратор событий.

Это код для моей функции:

хост.json:

 "version": "2.0",
 "logging": {
 "applicationInsights": {
 "samplingSettings": {
 "isEnabled": true,
 "excludedTypes": "Request"
 }
 }
 },
 "extensionBundle": {
 "id": "Microsoft.Azure.Functions.ExtensionBundle",
 "version": "[2.*, 3.0.0)"
 }
}

функция.json:

 "scriptFile": "__init__.py",
 "bindings": [
 {
 "type": "eventHubTrigger",
 "name": "events",
 "direction": "in",
 "eventHubName": "eventhub",
 "connection": "eventhub_connection",
 "cardinality": "many",
 "consumerGroup": "$Default",
 "dataType": "stream"
 }
 ]
}

init.py:

import logging
import azure.functions as func
def main(events: List[func.EventHubEvent]):
 for event in events:
 logging.info('Python EventHub trigger processed an event: %s',
  event.get_body().decode('utf-8'))
 logging.info(f'Function triggered to process a message: {event.get_body().decode()}')
 logging.info(f' EnqueuedTimeUtc = {event.enqueued_time}')
 logging.info(f' SequenceNumber = {event.sequence_number}')
 logging.info(f' Offset = {event.offset}')
# def main(event: func.EventHubEvent):
# logging.info(f'Function triggered to process a message: {event.get_body().decode()}')
# logging.info(f' EnqueuedTimeUtc = {event.enqueued_time}')
# logging.info(f' SequenceNumber = {event.sequence_number}')
# logging.info(f' Offset = {event.offset}')
# # Metadata
# for key in event.metadata:
# logging.info(f'Metadata: {key} = {event.metadata[key]}')

 "IsEncrypted": false,
 "Values": {
 "FUNCTIONS_WORKER_RUNTIME": "python",
 "AzureWebJobsStorage": "DefaultEndpointsProtocol=https;AccountName=storageaccount;AccountKey=storageacciuntaccesskey=;EndpointSuffix=core.windows.net",
 "eventhub_connection": "Endpoint=sb://eventhub01.servicebus.windows.net/;SharedAccessKeyName=function;SharedAccessKey=0omitted;EntityPath=eventhub"
 }
}

Я начал с базового кода Python для EventHub, предоставленного инструментами Azure Function Core. И тестировали различные фрагменты кода, найденные в онлайн-примерах из блогов людей и документов Microsoft.

При переключении на кардинальность: один -> я переключаюсь на код, который в данный момент закомментирован. Не знаю, должно ли так быть, просто мне так кажется.

В любом случае, независимо от настройки кардинальности или изменения типа данных между двоичным, потоковым или строковым. Моя функция просто не срабатывает.

Я могу запросить свой концентратор событий и просмотреть/прочитать события. Итак, я знаю свою политику, а общий ключ и тому подобное работают нормально. Я также использую только потребительскую группу $Default.

Я также попытался настроить функцию, активируемую HTTP, и эта функция запускается из Azure Monitor. Я вижу в логах каждый запрос, входящий в функцию.

Я делаю что-то неправильно в коде для моей функции eventhub? Возможно, я пропустил какой-то другой параметр конфигурации? Я уже проверил правила доступа к функции, но это действительно не имеет значения, не так ли? Функция извлекает событие из концентратора событий. Инициатор не отправляет данные.

Изменить: добавлена ​​конфигурация файла local.settings.json и обновлен файл function.json. Изменить 2: решение моей конкретной проблемы находится в комментариях к ответу.

Решение проблемы

Обновлять:

__init__.py функции:

from typing import List
import logging
import azure.functions as func
def main(events: List[func.EventHubEvent]):
 for event in events:
 logging.info('Python EventHub trigger processed an event: %s',
  event.get_body().decode('utf-8'))

Отправить сообщение в концентратор событий:

import asyncio
from azure.eventhub.aio import EventHubProducerClient
from azure.eventhub import EventData
async def run():
 # Create a producer client to send messages to the event hub.
 # Specify a connection string to your event hubs namespace and
 # the event hub name.
 producer = EventHubProducerClient.from_connection_string(conn_str="Endpoint=sb://testbowman.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=xxxxxx;EntityPath=test", eventhub_name="test")
 async with producer:
 # Create a batch.
 event_data_batch = await producer.create_batch()
 # Add events to the batch.
 event_data_batch.add(EventData('First event '))
 event_data_batch.add(EventData('Second event'))
 event_data_batch.add(EventData('Third event'))
 # Send the batch of events to the event hub.
 await producer.send_batch(event_data_batch)
loop = asyncio.get_event_loop()
loop.run_until_complete(run())

И, пожалуйста, убедитесь, что вы указали правильное имя концентратора событий:

Кажется, function.jsonу вас проблема, строка подключения не должна напрямую помещаться в элемент привязки.

Это должно быть, как показано ниже:

function.json

{
 "scriptFile": "__init__.py",
 "bindings": [
 {
 "type": "eventHubTrigger",
 "name": "events",
 "direction": "in",
 "eventHubName": "test",
 "connection": "testbowman_RootManageSharedAccessKey_EVENTHUB",
 "cardinality": "many",
 "consumerGroup": "$Default",
 "dataType": "binary"
 }
 ]
}

local.settings.json

{
 "IsEncrypted": false,
 "Values": {
 "AzureWebJobsStorage": "DefaultEndpointsProtocol=https;AccountName=0730bowmanwindow;AccountKey=xxxxxx;EndpointSuffix=core.windows.net",
 "FUNCTIONS_WORKER_RUNTIME": "python",
 "testbowman_RootManageSharedAccessKey_EVENTHUB": "Endpoint=sb://testbowman.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=xxxxxx;EntityPath=test"
 }
}