编辑“︁Airflow SqlSensor”︁（章节）

== 基本用法 ==

以下是 SqlSensor 的基本使用示例：

<syntaxhighlight lang="python">
from airflow import DAG
from airflow.sensors.sql import SqlSensor
from airflow.utils.dates import days_ago

dag = DAG(
    'sql_sensor_example',
    schedule_interval=None,
    start_date=days_ago(1),
)

# 定义一个 SqlSensor，检查表中是否存在符合条件的记录
wait_for_data = SqlSensor(
    task_id='wait_for_data',
    conn_id='my_db_connection',
    sql="SELECT COUNT(*) FROM my_table WHERE status = 'processed'",
    mode='poke',
    timeout=3600,
    poke_interval=60,
    dag=dag,
)
</syntaxhighlight>

=== 参数说明 ===
* '''conn_id'''：配置在 Airflow 中的数据库连接 ID
* '''sql'''：要执行的 SQL 查询
* '''mode'''：传感器模式，通常为 'poke'（持续检查）或 'reschedule'（在检查间隔期间释放工作线程）
* '''timeout'''：传感器等待的总时间（秒）
* '''poke_interval'''：两次检查之间的间隔时间（秒）