Data Engineering, Elt Pipeline, Apache Airflow, Kinesis Firehose, Snowflake Data Cloud.
orders_raw o join customer_raw c on o.o_custkey = c.C_custkey and o.batch_id = c.batch_id where o_orderstatus= 'F' group by c_name,o_orderdate, c.batch_id order by o_orderdate;""", ] snowflake_customers_sql_str = SnowflakeOperator( task_id='snowflake_raw_insert_customers', dag=dag,