如何在Python函数中使用Azure函数命令输出绑定？

Question

我正在尝试设置Azure函数，以从EventHub“ A”接收消息，然后根据使用功能绑定的输入消息将消息发送到EventHub“ B”或C的一个。

Azure函数支持EventHub的触发和输出绑定，但是，我不知道如何正确设置势在必行的输出绑定。

到目前为止，这是我的函数。 tabs =过程中％2cfunctionsv2％2cextensionv5＆amp; pivots =编程语言 - 语言 - python＃usage'rel =“ nofollow noreferrer”> docs ：

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "event",
      "type": "eventHubTrigger",
      "direction": "in",
      "eventHubName": "A",
      "consumerGroup": "myConsumerGroup",
      "connection": "aConnectionString"
    },
    {
      "type": "eventHub",
      "name": "B",
      "eventHubName": "B",
      "connection": "bConnectionString",
      "direction": "out"
    },
    {
      "type": "eventHub",
      "name": "C",
      "eventHubname": "C",
      "connection": "cConnectionString",
      "direction": "out"
    }
  ]
}

import logging
import azure.functions as func

def main(event: func.EventHubEvent, B: func.Out, C: func.Out):
  logging.info(f'########################################')
  logging.info(f'Function triggered to process a message:')
  logging.info(f'  EnqueuedTimeUtc = {event.enqueued_time}')
  logging.info(f'  SequenceNumber = {event.sequence_number}')
  logging.info(f'  Offset = {event.offset}')
  logging.info(f'----------------------------------------')
  logging.info(f'  Metadata: ')
  for key in event.metadata:
    logging.info(f'    key {key} = {event.metadata[key]}')
  logging.info(f'  Body = {event.get_body().decode()}')
  logging.info(f'----------------------------------------')
  logging.info(f'B={B}')
  logging.info(f'C={C}')
  logging.info(f'########################################')

带有输出bindings and func.unc.unc.ut and func.ut and func.out tymed tym the函数，azure，azure功能不会触发。没有，确实如此。

任何帮助将不胜感激。

Answer 1

我使用Azurite Vscode扩展名来弄清楚它：有几个问题：

• b的输出绑定名称中有一个下划线。这使得名字无效。
• func.out是一种通用类型，需要注释类型：例如：func.out [str]