from airflow.providers.postgres.operators.postgres import PostgresOperator
task = PostgresOperator( task_id='my_task', sql='SELECT COUNT(*) FROM my_table;', postgres_conn_id='my_postgres_conn', database='my_database' )
上一篇:AirflowPostgresOperator安全性-execution_timeout未被尊重?如果它花费太长时间,如何在数据库中终止进程?
下一篇:AirflowPostgresToGoogleCloudStorageOperator身份验证错误