gpt4 book ai didi

Airflow - 定义 xcom_push 函数的键值

转载 作者:行者123 更新时间:2023-12-05 00:47:56 28 4
gpt4 key购买 nike

我正在尝试在 Airflow 中传递一个 Python 函数。我不确定 xcom_push 函数的键和值应该是什么。任何人都可以提供帮助。谢谢

def db_log(**context):
db_con = psycopg2.connect(" dbname = 'name' user = 'user' password = 'pass' host = 'host' port = '5439' sslmode = 'require' ")
task_instance = context['task_instance']
task_instance.xcom_push(key=db_con, value = db_log)
return (db_con)

任何人都可以帮助获取 xcom_push 函数的正确键和值。谢谢..

最佳答案

在示例中可以找到正确的调用方式,例如:https://github.com/apache/incubator-airflow/blob/master/airflow/example_dags/example_xcom.py

所以这里应该是

task_instance.xcom_push(key=<string identifier>, value=<actual value / object>)

在你的情况下
task_instance.xcom_push(key="db_con", value=db_con)

关于Airflow - 定义 xcom_push 函数的键值,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50600895/

28 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com