Is it possible to get a schema name from say a Redshift connection in Airflow? If so how would one do it?

Question

Pretty much the title. I have a Redshift connection in Airflow and I want to get the schema name from what is specified in the connection so as to access that particular schema for an unload operation that the DAG performs.

For example in the staging environment, the DAG would reference "staging" as the schema name from what is specified in the connection.

P.S. I want to avoid using airflow.configuration.get to get the execution environment so as to tackle the scenario where the schema name doesn't match the execution environment exactly. It is safe to assume that the schema name specified in the Redshift connection will be valid.

question from:https://stackoverflow.com/questions/65837724/is-it-possible-to-get-a-schema-name-from-say-a-redshift-connection-in-airflow-i

Answer 1

Waitting for answers