如何解决如何将数据库连接传递到Airflow KubernetesPodOperator
我对KubernetesPodOperator
中的Airflow
感到困惑,我想知道如何通过load_users_into_table()
函数,该函数具有存储在{ conn_id
中的{1}}在Pod中?
在官方文档中,建议将connection
放在Airflow
中,但是我不知道之后如何在函数conn_id
中传递它。
要在广告连播中执行的功能(任务):
Secret
危险:
load_users_into_table()
解决方法
假设您想使用 K8sPodOperator 运行,您可以使用 argparse 并向 docker cmd 添加参数。这些行中的某些内容应该可以完成工作:
import argparse
def f(arg):
print(arg)
parser = argparse.ArgumentParser()
parser.add_argument('--foo',help='foo help')
args = parser.parse_args()
if __name__ == '__main__':
f(args.foo)
Dockerfile:
FROM python:3
COPY main.py main.py
CMD ["python","main.py","--foo","somebar"]
还有其他方法可以解决这个问题,例如使用秘密、configMaps 甚至 Airflow 变量,但这应该会让您继续前进。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。