0

我正在从 AWS Lambda 触发一个 DAG，它将接收我解析为的 s3 uri

file_name="{{ dag_run.conf['message'] }}"

效果很好。但是，在下一步中，我想使用

vars=file_name.split('/')
vendor_num=vars[len(vars)-2]

但是，dag 甚至无法导入。如何在 conf 中对某些路径进行硬编码以避免此错误？

4

0 回答 0