如何在 json 模板中传递气流 ts_nodash

Question

我需要从 Ariflow dag 调用 API。

以下是我在代码中使用的示例 json_string：

    def api_call_func(**context):
        source_file_name = context["dag_run"].conf["source_file_names"]
    json_data = { "filenames":[
                 {"FileName":[f'Source_credit_{{{{ ts_nodash }}}}']}
                  ]
                }

        json_string = json.dumps(json_data, 
                        skipkeys = True, 
                        allow_nan = True)
        requests.post(url = API_URL, data = json_string)

    api_task = PythonOperator(
    task_id='api_task',
    provide_context=True,
    python_callable=api_call_func,
    dag=dag,
    )

但它会导致以下响应：

<filenames>
         <FileName>f'Source_credit_{{ ts_nodash }}</FileName>
</filenames>

以下是 currentDateTime 所需的响应：

<filenames>
         <FileName>f'Source_credit_20210408010223</FileName> 
</filenames>

如何在 json 中传递 ts_nodash 宏？ 或者如何在 json 中传递 dag 的执行日期时间？

Answer 1

仅当包含模板的字符串作为参数传递给运算符的模板化参数时，才会处理模板。例如，op_argsPythonOperator 的参数。

在您的情况下，ts_nodash 的值作为PythonOperator 的参数传递给api_call_func()。因此，您可以使用context 参数来访问它：

json_data = {
    "ID": "A001-001",
    "SourceName": sourcefile,
    "filenames": [{"FileName": [f"Source_credit_{context['ts_nodash']}"]}],
}

注意，default variables 其余部分的值可以通过相同方式访问。