替换 Airflow 配置

按照本页面上的说明操作可以替换新环境和现有环境的 Airflow 配置选项。

创建更新环境时,您可以使用不同的值替换 Apache Airflow 配置选项。这样,您便可以根据自己的需求和要求调整 Airflow 实例。

替换新环境的配置

控制台

  1. 打开创建环境页面。

    打开“创建环境”页面

  2. Airflow 配置替换下,点击添加 Airflow 配置替换

  3. 输入该配置的和新

例如:

webserver dag_orientation RL

gcloud

在创建环境时替换 Airflow 配置选项:

gcloud composer environments create ENVIRONMENT_NAME \
    --location LOCATION \
    --airflow-configs=KEY=VALUE,KEY=VALUE,...

您需要将其中的:

  • ENVIRONMENT_NAME 替换为环境的名称。
  • LOCATION 替换为环境所在的 Compute Engine 区域。
  • KEY 替换为配置节和选项名称(两者用连字符分隔),例如 core-print_stats_interval
  • VALUE 替换为选项的相应值。

例如:

gcloud composer environments create test-environment \
    --location us-central1 \
    --airflow-configs=core-load_example=True,webserver-dag_orientation=TB 

操作完成后,该命令即终止。为了避免等待,可使用 --async 标志。如需查看其他示例,请参阅 gcloud composer environments create 参考页面。

API

如需在创建 Cloud Composer 环境期间使用 Cloud Composer REST API 替换 Airflow 属性,请执行以下操作:

  1. 构建 environments.create 请求。
  2. 在该请求中,填写 Environment 资源的可选 airflowConfigOverrides 字段。

替换现有环境的配置

控制台

  1. 打开环境页面。

    打开“环境”页面

  2. 在环境列表中,点击您的环境。“环境详情”页面会打开
  3. 导航到 Airflow 配置替换标签页。
  4. 点击修改
  5. 输入该配置的和新

例如:

webserver dag_orientation RL

gcloud

替换现有环境的 Airflow 配置选项:

gcloud composer environments update ENVIRONMENT_NAME \
  --location LOCATION \
  --update-airflow-configs=KEY=VALUE,KEY=VALUE,...

您需要将其中的:

  • ENVIRONMENT_NAME 替换为环境的名称。
  • LOCATION 替换为环境所在的 Compute Engine 区域。
  • KEY 替换为配置节和选项名称(两者用连字符分隔),例如 core-print_stats_interval
  • VALUE 替换为选项的相应值。

例如:

gcloud composer environments update test-environment \
    --location us-central1 \
    --update-airflow-configs=core-load_examples=True,webserver-dag_orientation=TB 

操作完成后,该命令即终止。为了避免等待,可使用 --async 标志。如需查看其他示例,请参阅 gcloud composer environments update 参考页面。

API

如需使用 Cloud Composer REST API 替换现有 Cloud Composer 环境的 Airflow 属性,请执行以下操作:

  1. 构建 environments.patch 请求。
  2. 在此请求中:

    • 如需将所有现有 Airflow 配置替换替换为指定的选项,请在 updateMask 参数中指定 config.softwareConfig.airflowConfigOverrides 掩码。
    • 如需替换特定 Airflow 配置选项,请在 updateMask 参数中指定 config.softwareConfig.airflowConfigOverrides. section-name 掩码。

后续步骤