如何在airflow中跨DAG任务访问凭据，而无需使用连接/变量

pip install hvac

from airflow import settings
from airflow.models import Connection

# 创建一个新的连接
conn = Connection(
    conn_id="vault_default",
    conn_type="vault",
    host="vault.example.com",
    port=8200,
    schema="",
    login="",
    password=""
)
settings.CONN_MANAGER.save(conn)

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
import hvac

def get_secret():
    client = hvac.Client(url='http://vault.example.com:8200')
    client.auth.approle.login(role_id='your-role-id', secret_id='your-secret-id')
    secret = client.secrets.kv.v2.read_secret_version(path='your-secret-path')
    return secret['data']['data']

def use_secret(**context):
    secret = get_secret()
    print(f"Retrieved secret: {secret}")

dag = DAG('example_dag', schedule_interval=None)

task = PythonOperator(
    task_id='use_secret_task',
    python_callable=use_secret,
    provide_context=True,
    dag=dag,
)