如何在另一个任务airflow中使用查询结果(bigquery运算符

from airflow import DAG
from airflow.providers.google.cloud.operators.bigquery import BigQueryExecuteQueryOperator
from airflow.operators.dummy_operator import DummyOperator
from datetime import datetime

default_args = {
    'owner': 'your_name',
    'start_date': datetime(2022, 1, 1),
    'retries': 1,
    'retry_delay': timedelta(minutes=5),
}

dag = DAG('bigquery_example', default_args=default_args, schedule_interval='@daily')

query = """
SELECT column1, column2
FROM your_table
WHERE condition
"""

bigquery_operator = BigQueryExecuteQueryOperator(
    task_id='execute_query',
    sql=query,
    use_legacy_sql=False,
    destination_dataset_table='your_project.your_dataset.your_table',
    dag=dag
)

start_operator = DummyOperator(task_id='start', dag=dag)

# 示例任务1：将查询结果发送到消息队列
send_to_queue_operator = YourCustomOperator(
    task_id='send_to_queue',
    message=query_result,
    dag=dag
)

# 示例任务2：进行数据处理
data_processing_operator = YourCustomOperator(
    task_id='data_processing',
    data=query_result,
    dag=dag
)

start_operator >> bigquery_operator >> [send_to_queue_operator, data_processing_operator]