如何在 Airflow 操作员中打印唯一的消息？

Question

在气流中，可以print()按照此处的建议使用简单或记录器写入日志但是，当尝试在操作员内部打印时，这将不起作用。我有以下代码：for i in range(5, 0, -1):    gcs_export_uri_template = ["adstest/{{ macros.ds_format(macros.ds_add(ds, -params.i), '%Y-%m-%d', '%Y/%m/%d') }}/*"]    update_bigquery = GoogleCloudStorageToBigQueryOperator(        dag=dag,        task_id='load_ads_to_BigQuery-{}'.format(i),        bucket=GCS_BUCKET_ID,        destination_project_dataset_table=table_name_template,        source_format='CSV',        source_objects=gcs_export_uri_template,        schema_fields=dc(),        params={'i': i},        create_disposition='CREATE_IF_NEEDED',        write_disposition='WRITE_APPEND',        skip_leading_rows=1,        google_cloud_storage_conn_id=CONNECTION_ID,        bigquery_conn_id=CONNECTION_ID    )现在说我想打印，"My name is load_ads_to_BigQuery-{}".format{i) 因为你可以看到这个打印是每个操作员的 uniuqe。如果我这样做：for i in range(5, 0, -1):    print("My name is load_ads_to_BigQuery-{}".format{i))    gcs_export_uri_template = ...    update_bigquery = GoogleCloudStorageToBigQueryOperator(...)所有 5 个操作员将打印所有 5 个打印件。在我的情况下这是不正确的。打印件必须在GoogleCloudStorageToBigQueryOperator.我怎样才能做到这一点？