Я пытаюсь проверить некоторые вещи с потоком воздуха, но столкнулся с ошибкой KeyError: 'Variable xxl_credential does not exist'
. Когда я пытаюсь создать переменную через пользовательский интерфейс, он показывает, но через некоторое время он исчезает. И когда я хочу добавить через код, он по-прежнему выдает ту же ошибку. Мой код ниже:
def get_data_from_GBQ():
global customer_data
customer_data_query = """ SELECT addressShippingName, email, mobile FROM `xxlhoreca-bi.DataImport.orders` where mobile <> "" LIMIT 2 """
# Creating a connection to the google bigquery
client = bigquery.Client.from_service_account_json(xxl_credential_var)
customer_data = client.query(customer_data_query).to_dataframe()
print(customer_data)
xxl_credential = "C:/Users/nazrin.guliyeva/Documents/GitHub/airflow-tutorial/examples/intro-example/credentials/cred_xxl.json"
xxl_credential_var = Variable.get("xxl_credential")
dag = DAG(
'odoo_connection_dag',
default_args=default_args,
description='A connection between ',
schedule_interval=timedelta(days=1),
template_searchpath = xxl_credential_var,
)
# t1, t2 are examples of tasks created by instantiating operators
t1 = PythonOperator(
task_id='get_data_from_gbq',
python_callable=get_data_from_GBQ,
dag=dag,
)