python - 如何将多个参数传递给 Azure Durable Activity Function

Question

我的协调器接收一个有效负载，该有效负载包含需要与其他数据集一起传递给事件函数的指令。
如何将多个参数传递给事件函数？还是我必须将所有数据混合在一起？

def orchestrator_function(context: df.DurableOrchestrationContext):
    
    # User defined configuration
    instructions: str = context.get_input()

    task_batch = yield context.call_activity("get_tasks", None)
    
    # Need to pass in instructions too
    parallel_tasks = [context.call_activity("perform_task", task) for task in task_batch]

    results = yield context.task_all(parallel_tasks)
    
    return results

perform_task事件需要来自 task_batch 的两个项目和用户输入 instructions我在我的 function.json 里做些什么吗？ ?
解决方法
不理想，但我可以将多个参数作为单个元组传递

something = yield context.call_activity("activity", ("param_1", "param_2"))

然后我只需要引用事件中参数的正确索引。

Answer 1

似乎没有教科书的方式来做到这一点。我选择给我的单个参数一个通用名称，如 parameter或 payload .
然后在协调器中传递值时，我这样做:

payload = {"value_1": some_var, "value_2": another_var}
something = yield context.call_activity("activity", payload)

然后在事件功能中，我再次打开它。
编辑:一些隐藏的文档似乎表明 https://docs.microsoft.com/en-us/azure/azure-functions/durable/durable-functions-error-handling?tabs=python