在Airflow中,MsSqlOperator是用于执行SQL语句的操作符。它执行SQL语句并返回SQL Server的响应。
下面是一个使用MsSqlOperator的示例代码:
from airflow import DAG
from airflow.operators.mssql_operator import MsSqlOperator
from datetime import datetime
default_args = {
'owner': 'airflow',
'start_date': datetime(2021, 1, 1),
}
dag = DAG('mssql_example', default_args=default_args, schedule_interval='@once')
t1 = MsSqlOperator(
task_id='execute_sql',
mssql_conn_id='mssql_default',
sql="SELECT * FROM table_name",
dag=dag
)
t1
在上面的示例中,我们创建了一个名为mssql_example
的DAG,并定义了一个MsSqlOperator
任务,用于执行SELECT * FROM table_name
的SQL语句。 mssql_conn_id
参数指定了连接到SQL Server的连接。sql
参数指定要执行的SQL语句。
当任务运行时,MsSqlOperator
将执行SQL语句,并返回SQL Server的响应。你可以使用任务的输出来访问响应,如下所示:
result = t1.output
print(result)
请注意,MsSqlOperator
任务的输出是一个字符串,其中包含SQL Server的响应。你可以根据需要对这个响应进行进一步的处理。