Exclusive — Airflow Xcom

Старая версия сайта: old.geospb.ru

Санкт-Петербург, пр. Энгельса, д. 107, к. 3

8 (812) 438-33-66

info@geospb.ru

Exclusive — Airflow Xcom

Because standard XComs save data directly to your Airflow metadata database (like PostgreSQL or MySQL), large files will slow down your system. Passing huge CSV files, large dataframes, or images via standard XCom can crash your database and stop your entire data pipeline.

By default, when a task returns a value, Airflow automatically serializes it and stores it in the metadata database ( airflow.db ). airflow xcom exclusive

: If a Python task returns a value at the end of its function execution, Airflow automatically saves it. If that data is not needed downstream, return None or set do_xcom_push=False in your operator configuration. Because standard XComs save data directly to your

The TaskFlow API drastically reduces boilerplate code while maintaining identical underlying database operations. 3. Custom XCom Backends: Breaking the Database Constraint : If a Python task returns a value

Have no product in the cart!
0