| BashOperator | 执行 shell 命令 |
|---|---|
| PythonOperator | 执行 Python 可调用对象 |
| SQL 类 | 按数据库 Provider 提供，如 PostgresOperator |
| Provider 包 | apache-airflow-providers-* 需单独安装 |
两类算子示例
两类算子示例
from airflow.operators.bash import BashOperator
from airflow.operators.python import PythonOperator
BashOperator(task_id="sh", bash_command="hive -e 'select 1'")
PythonOperator(task_id="py", python_callable=lambda: print("ok"))
# SQL 算子来自对应 Provider，例如 PostgresOperator(sql="select 1")算子参数支持 Jinja 模板：bash_command 里可用 {{ ds }}（逻辑日期）、{{ data_interval_start }} 等内置变量。