Cloud Composer 1 | Cloud Composer 2
本页面介绍了如何针对新环境或现有环境启用将 Airflow 任务日志保存到环境存储桶的功能。
您可以选择启用任务日志与环境存储桶的同步。
准备工作
从 Cloud Composer 2.8.0 版开始,默认情况下,所有环境都不会在环境的存储桶中存储任务日志。您仍然可以在 Cloud Logging 和 Airflow 界面中查看任务日志。
启用此功能后,日志会同时保存到 Cloud Logging 和环境的存储桶中。
升级环境时,用于在环境存储桶中保存日志的配置不会更改。例如,如果将已保存到环境存储桶的环境升级到更高版本,该环境会继续将日志保存到环境的存储桶中。
如果您禁止将任务日志保存到环境的存储桶,系统不会自动删除已经保存到环境存储桶的日志。
如需启用或停用此选项,您可以使用 Google Cloud CLI、Cloud Composer API 或 Terraform。您无法通过 Google Cloud 控制台更改此选项。
启用或停用在创建环境时将任务日志保存到环境存储桶的功能
gcloud
创建环境时,以下参数指定必须如何保存 Airflow 任务日志:
--disable-logs-in-cloud-logging-only
参数用于将 Airflow 任务日志保存到环境的存储桶中。--enable-logs-in-cloud-logging-only
参数禁止将 Airflow 任务日志保存到环境的存储桶。日志仅保存到 Cloud Logging。
gcloud composer environments create ENVIRONMENT_NAME \
--location LOCATION \
--disable-logs-in-cloud-logging-only
请替换以下内容:
ENVIRONMENT_NAME
:您的环境的名称。LOCATION
:环境所在的区域。
示例:
gcloud composer environments create example-environment \
--location us-central1 \
--disable-logs-in-cloud-logging-only
API
创建环境时,在环境 > EnvironmentConfig > DataRetentionConfig > TaskLogsRetentionConfig资源中,指定必须如何保存 Airflow 任务日志:
CLOUD_LOGGING_AND_CLOUD_STORAGE
,用于将日志保存到环境的存储桶和 Cloud Logging。CLOUD_LOGGING_ONLY
(用于仅将日志保存到 Cloud Logging)。
{
"name": "projects/PROJECT_ID/locations/LOCATION/environments/ENVIRONMENT_NAME",
"config": {
"dataRetentionConfig": {
"taskLogsRetentionConfig": {
"storageMode": "CLOUD_LOGGING_AND_CLOUD_STORAGE"
}
}
}
}
请替换以下内容:
ENVIRONMENT_NAME
:您的环境的名称。LOCATION
:环境所在的区域。PROJECT_ID
:项目 ID。
示例:
// POST http://composer.googleapis.com/v1/{parent=projects/*/locations/*}/environments
{
"name": "projects/example-project/locations/us-central1/environments/example-environment",
"config": {
"dataRetentionConfig": {
"taskLogsRetentionConfig": {
"storageMode": "CLOUD_LOGGING_AND_CLOUD_STORAGE"
}
}
}
}
Terraform
创建环境时,task_logs_retention_config
块中的 storage_mode
字段会指定必须如何保存 Airflow 任务日志:
CLOUD_LOGGING_AND_CLOUD_STORAGE
,用于将日志保存到环境的存储桶和 Cloud Logging。CLOUD_LOGGING_ONLY
(用于仅将日志保存到 Cloud Logging)。
resource "google_composer_environment" "example" {
provider = google-beta
name = "ENVIRONMENT_NAME"
region = "LOCATION"
config {
data_retention_config {
task_logs_retention_config {
storage_mode = "CLOUD_LOGGING_AND_CLOUD_STORAGE"
}
}
}
请替换以下内容:
ENVIRONMENT_NAME
:您的环境的名称。LOCATION
:环境所在的区域。
示例:
resource "google_composer_environment" "example" {
provider = google-beta
name = "example-environment"
region = "us-central1"
config {
data_retention_config {
task_logs_retention_config {
storage_mode = "CLOUD_LOGGING_AND_CLOUD_STORAGE"
}
}
}
}
启用或停用将任务日志保存到现有环境的环境存储桶的功能
gcloud
在更新环境时,以下参数可启用或停用将 Airflow 任务日志保存到环境存储桶的功能:
--disable-logs-in-cloud-logging-only
参数用于将 Airflow 任务日志保存到环境的存储桶中。日志会保存到环境的存储桶和 Cloud Logging。--enable-logs-in-cloud-logging-only
参数禁止将 Airflow 任务日志保存到环境的存储桶。日志仅保存到 Cloud Logging。
如需将 Airflow 日志保存在环境的存储桶中,请执行以下操作:
gcloud composer environments update ENVIRONMENT_NAME \
--location LOCATION \
--disable-logs-in-cloud-logging-only
请替换以下内容:
ENVIRONMENT_NAME
:您的环境的名称。LOCATION
:环境所在的区域。
示例:
gcloud composer environments update example-environment \
--location us-central1 \
--disable-logs-in-cloud-logging-only
API
构建
environments.patch
API 请求。在此请求中:
在
updateMask
参数中,指定config.dataRetentionConfig.taskLogsRetentionConfig.storageMode
掩码。在请求正文中,指定必须如何保存 Airflow 任务日志:
CLOUD_LOGGING_AND_CLOUD_STORAGE
,用于将日志保存到环境的存储桶和 Cloud Logging。CLOUD_LOGGING_ONLY
(用于仅将日志保存到 Cloud Logging)。
{
"config": {
"dataRetentionConfig": {
"taskLogsRetentionConfig": {
"storageMode": "CLOUD_LOGGING_AND_CLOUD_STORAGE"
}
}
}
}
示例:
// PATCH http://composer.googleapis.com/v1/projects/example-project/
// locations/us-central1/environments/example-environment?updateMask=
// config.dataRetentionConfig.taskLogsRetentionConfig.storageMode
{
"config": {
"dataRetentionConfig": {
"taskLogsRetentionConfig": {
"storageMode": "CLOUD_LOGGING_AND_CLOUD_STORAGE"
}
}
}
}
Terraform
在 task_logs_retention_config
代码块的 storage_mode
字段中,指定必须如何保存 Airflow 任务日志:
CLOUD_LOGGING_AND_CLOUD_STORAGE
,用于将日志保存到环境的存储桶和 Cloud Logging。CLOUD_LOGGING_ONLY
(用于仅将日志保存到 Cloud Logging)。
resource "google_composer_environment" "example" {
provider = google-beta
name = "ENVIRONMENT_NAME"
region = "LOCATION"
config {
data_retention_config {
task_logs_retention_config {
storage_mode = "CLOUD_LOGGING_AND_CLOUD_STORAGE"
}
}
}
请替换以下内容:
ENVIRONMENT_NAME
:您的环境的名称。LOCATION
:环境所在的区域。
示例:
resource "google_composer_environment" "example" {
provider = google-beta
name = "example-environment"
region = "us-central1"
config {
data_retention_config {
task_logs_retention_config {
storage_mode = "CLOUD_LOGGING_AND_CLOUD_STORAGE"
}
}
}
}