KeyError: «Переменная xxl_credential не существует» - PullRequest
0 голосов
/ 22 октября 2019

Я пытаюсь проверить некоторые вещи с потоком воздуха, но столкнулся с ошибкой 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,
)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...