无法使用BashOperator运行Python脚本。

0

【以下的问题经过翻译处理】 我需要使用BashOperator运行一个Python脚本。我把脚本放在S3存储桶的dags文件夹中,并使用BashOperator运行我的DAG。然而它显示错误:python3: can't open file 'hello_world.py': No such file or directory

我还注意到Airflow worker在一个临时脚本位置运行命令,例如 /tmp/airflowtmpx03mq_qp/run_scriptlolkuw_q。此路径在每个DAG运行时都会更改。在这种情况下,我该如何运行脚本?请帮我提供Managed Airflow中最简单的方法。谢谢。

profile picture
전문가
질문됨 6달 전20회 조회
1개 답변
0

【以下的回答经过翻译处理】 你好!

放置在包含 DAG 的 S3 文件夹中的任何内容都将同步到 MWAA worker 上的 /usr/local/airflow/dags。因此,要运行名为“hello_world.py”的文件,您可以使用 bash 命令“python3 /usr/local/airflow/dags/hello_world.py”

谢谢!

profile picture
전문가
답변함 6달 전

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인

관련 콘텐츠