Как отправлять данные на событие, используя функцию таймера запуска Azure v2 в Python

Я пытаюсь отправлять данные каждые 10 секунд в концентратор событий с помощью функций Azure v2. Вот мой код для function.json

    {
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "mytimer",
      "type": "timerTrigger",
      "direction": "in",
      "schedule": "*/10 * * * * *"
    },
    {
      "type": "eventHub",
      "name": "$return",
      "eventHubName": "sqlserverstreaming",
      "connection": "amqps://desrealtimestreaming.servicebus.windows.net",
      "direction": "out"
  }
  ]
}

Вот мой код для init.py

    import datetime
import logging
import azure.functions as func


def main(mytimer: func.TimerRequest) -> None:
    utc_timestamp = datetime.datetime.utcnow().replace(
        tzinfo=datetime.timezone.utc).isoformat()
    print('saran')
    return 'Message created at: {}'.format(utc_timestamp)
    # if mytimer.past_due:
    #     logging.info('The timer is past due!')
    # logging.info('Python timer trigger function ran at %s', utc_timestamp)

И я получаю следующую ошибку.

 Executed 'Functions.TimerTriggerFUnction' (Failed, Id=fa924331-418f-427f-b672-f525c3ee6b61)
[07-08-2019 09:03:40] System.Private.CoreLib: Exception while executing function: Functions.TimerTriggerFUnction. System.Private.CoreLib: Result: Failure
Exception: FunctionLoadError: cannot load the TimerTriggerFUnction function: Python return annotation "NoneType" does not match binding type "eventHub"
Stack:   File "C:\Users\SivaSakthiVelan\AppData\Roaming\npm\node_modules\azure-functions-core-tools\bin\workers\python\deps\azure\functions_worker\dispatcher.py", line 240, in _handle__function_load_request
    function_id, func, func_request.metadata)
  File "C:\Users\SivaSakthiVelan\AppData\Roaming\npm\node_modules\azure-functions-core-tools\bin\workers\python\deps\azure\functions_worker\functions.py", line 241, in add_function
    f'Python return annotation "{return_pytype.__name__}" '

1 ответ

Решение

Измените тип возврата с None в str

def main(mytimer: func.TimerRequest) -> str:

Смотрите здесь для полного примера: https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-event-hubs

Кроме того, ваш connection Свойство должно иметь имя параметра приложения, которое содержит строку подключения, а не саму строку подключения (см. также в примере), например, так:

  "type": "eventHub",
  "name": "$return",
  "eventHubName": "sqlserverstreaming",
  "connection": "MyConnStringAppSetting",
  "direction": "out"

А затем создайте настройку приложения с именем MyConnStringAppSetting и вставьте туда свою полную строку подключения.