需要访问气流中DockerOperator中的调度时间

Question

需要访问进度表时间在气流的码头操作员。例如

t1 = DockerOperator(
task_id="task",
dag=dag,
image="test-runner:1.0",
docker_url="xxx.xxx.xxx.xxx:2376",
environment={"FROM": "{{(execution_date + macros.timedelta(hours=6,minutes=(30))).isoformat()}}"})

基本上，我需要将计划时间作为码头环境填充。

Answer 1

正如其他海报所提到的，气流1.9中的DockerOperator只是期望command字段被模板化，但是修改操作符上的可模板字段是相当简单的。

from airflow.operators import DockerOperator
DockerOperator.template_fields = (command, environment)

然后你可以像往常一样实例化你的操作符。

Answer 2

(快速更新:)

可以对DockerOperator的环境和命令参数进行模板化。我写了一篇文章：https://marclamberti.com/blog/how-to-use-dockeroperator-apache-airflow/

此外，请不要犹豫地查看源代码，看看哪个参数可以模板化或不模板化：operator.py祝您愉快