Astro SDK

append

Append the source table rows into a destination table.

cleanup

Clean up temporary tables once either the DAG or upstream tasks are done

dataframe

This decorator will allow users to write python functions while treating SQL tables as dataframes

export_file

Convert ExportFileOperator into a function. Returns XComArg.

load_file

Load a file or bucket into either a SQL table or a pandas dataframe.

merge

Merge the source table rows into a destination table.

run_raw_sql

Given a python function that returns a SQL statement and (optional) tables, execute the SQL statement and output the result into a SQL table

transform

Given a python function that returns a SQL statement and (optional) tables, execute the SQL statement and output the result into a SQL table.

drop_table

Drops a table.

transform_file

This function returns a Table object that can be passed to future tasks from specified SQL file.