DAGがエアフローで実行を終了すると、XCOMオブジェクトを削除する方法

Question

XCOMに大規模なjsonファイルがありますが、これは後でDAGの実行が完了しても不要ですが、XcomオブジェクトはすべてUIデータ、DAGの実行が完了したら、プログラムでXCOMを削除する方法はありますか？

は、DAGの実行が終了するとXCOMを削除するには、そのタスクを追加する必要が

Answer 1

はあなたmetadatadb（sqlliteはPostgreSQL、MySQLの...）に依存していただきありがとうございます。

delete_xcom_task = PostgresOperator(
     task_id='delete-xcom-task', 
     postgres_conn_id='airflow_db', 
     sql="delete from xcom where dag_id=dag.dag_id and 
      task_id='your_task_id' and execution_date={{ ds }}", 
     dag=dag) 

ダグを実行する前にクエリを確認できます。

データプロファイリング - > Ad Hocクエリ - > airflow_db - >クエリ - >実行！