如何从推送至Airflow XCom的字典中提取指定键值

你给出的在Jinja模板大括号外加[value]的写法无法实现需求，原因是Jinja模板只会渲染被{{ }}包裹的表达式，括号外的内容会被直接识别为普通字符串拼接，不会执行字典取值逻辑。

和你现有单值写法风格一致的可行方案非常简单：把字典取值的逻辑整体放到Jinja双大括号内部即可，语法和普通Python字典取值完全兼容。

基础写法（固定字段名场景） #

如果你要提取的字典字段名是固定值，比如要取键为model_id的字段值，写法如下：

f"model_id={{{{ ti.xcom_pull(task_ids='train', key='{task_id}').get('model_id') }}}}"

推荐使用字典的.get()方法而非直接写['model_id']取值，你可以在.get()里传入第二个参数作为默认值，比如.get('model_id', 0)，避免XCom存储的字典缺少目标键时直接触发Jinja渲染错误、导致任务失败。

动态字段名场景 #

如果你要提取的字段名本身是Python侧的动态变量（比如存在变量extract_key中），直接用f-string把字段名拼接到.get()的参数位置即可：

extract_key = "target_field"
f"model_id={{{{ ti.xcom_pull(task_ids='train', key='{task_id}').get('{extract_key}') }}}}"

注意事项 #

• 所有XCom拉取、数据处理的表达式逻辑必须全部放在{{ }}边界内部，Jinja才会将其识别为可执行的Python语法
• 禁止将字典索引、属性访问等逻辑写在双大括号外侧，外侧内容会被原样作为字符串拼接，不会执行任何计算逻辑

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