Добавить my_con_test_postgre.py

2025-09-07 15:13:03 +04:00
parent 010ed90aeb
commit dd32cdb5eb
1 changed files with 16 additions and 0 deletions
--- a/my_con_test_postgre.py
+++ b/my_con_test_postgre.py
@@ -0,0 +1,16 @@
+from airflow import DAG
+from airflow.providers.postgres.operators.postgres import PostgresOperator
+from datetime import datetime
+
+with DAG(
+    dag_id="test_postgres_connection",
+    start_date=datetime(2023, 1, 1),
+    schedule_interval=None,
+    catchup=False,
+) as dag:
+
+    test_connection = PostgresOperator(
+        task_id="test_postgres",
+        postgres_conn_id="my_con_test_postgre",
+        sql="SELECT 1;",
+    )