Python开发Azure Durable Function时如何让Activity Function接受JSON输入

报错的核心原因是你在编排器（Orchestrator）中已经通过json.loads()把原始JSON字符串转为了Python字典对象，调用call_activity时直接将字典传给了活动函数（HelloActivity），但活动函数的入参标注为str类型，且直接用+运算符将入参和字符串拼接，Python不允许字典和字符串直接相加，因此触发类型错误。

修正方案 #

直接修改HelloActivity的代码，适配字典类型的入参即可，修改后的代码如下：

import logging
import json
from typing import Dict, Any

def main(datajson: Dict[str, Any]) -> str:
    # 输出日志时将字典转为JSON字符串即可正常打印
    logging.info(f"Activity datajson : {json.dumps(datajson, ensure_ascii=False)}")
    # 后续可直接按字典规则读取字段，例：datajson.get("你的字段名")
    return "Hello world"

可选优化建议 #

• 编排器中取输入建议使用官方公开方法context.get_input()替代私有属性context._input，避免后续版本更新私有属性变更导致报错，修改对应代码行即可：

  data = context.get_input()
  

如果确实需要传入字符串格式的JSON到活动函数，也可以在编排器调用时直接传未解析的原始JSON字符串，不需要做json.loads处理。

内容的提问来源于stack exchange，提问作者Kenny_I