Поток воздуха, получаемый от оператора Postgres - PullRequest
Новая
       6

Поток воздуха, получаемый от оператора Postgres

0 голосов
/ 29 октября 2019

My Airflow DAG имеет оператора Postgres, который мне хотелось бы знать, на сколько строк это влияет. Вот пример моей задачи: 

task4 = PostgresOperator(
    task_id='empty_staging',
    sql='DELETE FROM staging.table',
    postgres_conn_id='some_db_conn',
    autocommit=True,
    dag=dag,
)

Когда эта задача выполнена, это все, что осталось в журналах: 

[2019-10-29 15:08:43,944] {logging_mixin.py:95} INFO - [[34m2019-10-29 15:08:43,943[0m] {[34mlocal_task_job.py:[0m105} INFO[0m - Task exited with return code 0[0m

Насколько я могу судить, естьнет пр-испеченного способа записи строк, затронутых в Операторе Postgres? Как мне записать, что случилось?

1 Ответ

0 голосов
/ 29 октября 2019

Вы пытались "вернуть *" - он вернет все данные, которые были удалены, чтобы вы могли посчитать массив в этой точке, чтобы получить счет. 

 sql='DELETE FROM staging.table returning *',
...