在Airflow 2.0中,如果无法自动确定凭据(如GOOGLE_APPLICATION_CREDENTIALS
),可以使用以下代码示例来解决这个问题:
export GOOGLE_APPLICATION_CREDENTIALS=/path/to/credentials.json
from airflow import DAG
from airflow.operators.python import PythonOperator
def my_task():
# 在此处执行您的任务逻辑
dag = DAG("my_dag", ...)
with dag:
task = PythonOperator(
task_id="my_task",
python_callable=my_task,
env={
"GOOGLE_APPLICATION_CREDENTIALS": "/path/to/credentials.json"
}
)
请注意,这将在每个任务运行时将凭据路径添加到任务的环境变量中。
airflow.cfg
中添加以下配置:[core]
# 其他配置项...
google_application_credentials = /path/to/credentials.json
然后重新启动Airflow服务。
通过以上方法,您应该能够解决“Airflow 2.0 - 无法自动确定凭据(GOOGLE_APPLICATION_CREDENTIALS)”的问题,并成功使用凭据进行任务和操作。