Cloud Composer 1 | Cloud Composer 2 | Cloud Composer 3
Nesta página, você aprenderá como definir janelas de manutenção para seus ambientes.
Sobre as janelas de manutenção
Uma janela de manutenção é um período em que você permite o Cloud Composer para executar operações de manutenção. Por exemplo, você pode garantir que as execuções de tarefas críticas não sejam interrompidas especificando janelas de manutenção fora dos horários de programação do DAG.
Com as janelas de manutenção, você tem controle sobre os períodos em que a manutenção pode ocorrer no seu ambiente:
Se você definir janelas de manutenção personalizadas para seu ambiente, O Cloud Composer realiza manutenção durante esses períodos definidos.
Se você não definir janelas de manutenção personalizadas para o ambiente, O Cloud Composer faz a manutenção durante janelas de manutenção.
O que acontece durante as janelas de manutenção
Ao especificar janelas de manutenção, você fornece pelo menos 12 horas de tempo uma única semana para operações de manutenção:
O ambiente permanece disponível durante as janelas de manutenção. Alguns componentes do seu ambiente podem ficar temporariamente indisponíveis quando as operações de manutenção estiverem em andamento.
As 12 horas são necessárias para que o Cloud Composer tenha tempo suficiente para programar e realizar todas as operações de manutenção. Isso não significa que as operações de manutenção levam 12 horas ou acontecem toda semana.
Ainda é possível executar seus DAGs durante as janelas de manutenção, É aceitável que algumas tarefas possam ser interrompidas e repetidas. Se você executar DAGs durante as janelas de manutenção, ative as tentativas de repetição de tarefas. É possível configurar novas tentativas de tarefas no nível da configuração do Airflow, do DAG ou da tarefa.
As tarefas que levam menos de 55 minutos para serem executadas geralmente não são afetadas por operações de manutenção, mas ainda precisam ter as tentativas repetidas ativadas para resistir a reinicializações do programador. O programador pode ser reiniciado durante operações padrão do Cloud Composer, fora das janelas de manutenção.
O Cloud Composer informa aos workers do Airflow que uma operação de manutenção está prestes a acontecer. Um worker do Airflow finaliza as tarefas já iniciadas e não escolhe novas. Essas novas tarefas são executadas por workers do Airflow que não passar por operações de manutenção.
Se você usar um ambiente altamente resilient, os componentes do Airflow no seu ambiente provavelmente serão reiniciados em momentos diferentes durante uma operação de manutenção (isso depende do tipo de operação de manutenção). No geral, o uso de um ambiente altamente resiliente reduz o tempo de inatividade do ambiente durante as operações de manutenção.
As operações de manutenção têm os seguintes efeitos no seu ambiente:
A interface do Airflow pode estar temporariamente indisponível.
Alterar alguns parâmetros do seu ambiente ou fazer upgrade para uma versão posterior temporariamente.
Consultas SQL diretas ao banco de dados do Airflow podem levar mais tempo do que o normal e podem exigir novas tentativas.
Algumas tarefas do Airflow que levam mais de 55 minutos executar pode ser interrompido. Depois que a operação de manutenção for concluída, o Airflow vai programar novas tentativas para essas tarefas (se não tiver sido configurado de outra forma).
Janelas de manutenção padrão
As janelas de manutenção padrão no Cloud Composer 2 vão de 00:00:00 às 04:00:00 (GMT) às sextas, sábados e domingos de todas as semanas.
Como usar janelas de manutenção
As operações de manutenção podem afetar a execução dos DAGs e do Airflow tarefas. Portanto, recomendamos que você faça o seguinte:
Defina janelas de manutenção para seus ambientes do Cloud Composer.
Programe as execuções do DAG fora das janelas de manutenção especificadas usando Parâmetros
start_date
eschedule_interval
no seus DAGs.
Especificar janelas de manutenção para novos ambientes
É possível especificar janelas de manutenção ao criar um ambiente. Para mais informações, consulte Criar ambientes.
Especificar janelas de manutenção para ambientes atuais
Console
Para definir ou alterar janelas de manutenção de um ambiente atual, atualize o ambiente:
No console do Google Cloud, acesse a página Ambientes.
Selecione o ambiente.
Acesse a guia Configuração do ambiente.
Ao lado da entrada Janelas de manutenção, clique em Editar.
Na caixa de diálogo Janelas de manutenção, marque a caixa de seleção Definir horários personalizados para janelas de manutenção.
Defina o Horário de início, o Fuso horário, os Dias e a Duração para que o horário combinado para a programação especificada seja de pelo menos 12 horas em uma janela de 7 dias. Por exemplo, um período de quatro horas toda segunda, quarta e sexta-feira fornece o tempo necessário.
Clique em Salvar e aguarde até que o ambiente seja atualizado.
gcloud
Quando você atualiza um ambiente, os seguintes argumentos definem os parâmetros das janelas de manutenção:
--maintenance-window-start
define o horário de início de uma janela de manutenção.--maintenance-window-end
define o horário de término de uma janela de manutenção.--maintenance-window-recurrence
define a recorrência da janela de manutenção.
gcloud composer environments update ENVIRONMENT_NAME \
--location LOCATION \
--maintenance-window-start 'DATETIME_START' \
--maintenance-window-end 'DATETIME_END' \
--maintenance-window-recurrence 'MAINTENANCE_RECURRENCE'
Substitua:
ENVIRONMENT_NAME
pelo nome do ambiente;DATETIME_START
pela data e hora de início no formato de entrada de data/hora. Somente a hora especificada do dia é usada, a data especificada é ignorada.DATETIME_END
pela data e hora de término no formato de entrada de data/hora. Somente a hora especificada do dia é usada, a data especificada é ignorada. A data e a hora especificadas precisam ser posteriores à data de início.MAINTENANCE_RECURRENCE
por um RFC 5545 RRULE para a recorrência de janelas de manutenção. O Cloud Composer é compatível com dois formatos:O formato
FREQ=DAILY
especifica uma recorrência diária.O formato
FREQ=WEEKLY;BYDAY=SU,MO,TU,WE,TH,FR,SA
especifica uma recorrência nos dias da semana selecionados.
O exemplo a seguir especifica uma janela de manutenção de seis horas entre a 1h e 07:00 (UTC) às quartas-feiras, aos sábados e aos domingos. A data de 1º de janeiro de 2023 é ignorada.
gcloud composer environments update example-environment \
--location us-central1 \
--maintenance-window-start '2023-01-01T01:00:00Z' \
--maintenance-window-end '2023-01-01T07:00:00Z' \
--maintenance-window-recurrence 'FREQ=WEEKLY;BYDAY=SU,WE,SA'
API
Crie uma solicitação de API
environments.patch
.Nesta solicitação:
No parâmetro
updateMask
, especifique a máscaraconfig.maintenanceWindow
.No corpo da solicitação, especifique os parâmetros das janelas de manutenção.
{
"config": {
"maintenanceWindow": {
"startTime": "DATETIME_START",
"endTime": "DATETIME_END",
"recurrence": "MAINTENANCE_RECURRENCE"
}
}
}
Substitua:
DATETIME_START
pela data e hora de início no formato de entrada de data/hora. Somente a hora especificada do dia é usada, a data especificada é ignorada.DATETIME_END
pela data e hora de término no formato de entrada de data/hora. Somente a hora especificada do dia é usada, a data especificada é ignorada. A data e hora especificadas precisam ser posteriores à data de início.MAINTENANCE_RECURRENCE
por um RFC 5545 RRULE para a recorrência de janelas de manutenção. O Cloud Composer é compatível com dois formatos:- O formato
FREQ=DAILY
especifica uma recorrência diária. - O formato
FREQ=WEEKLY;BYDAY=SU,MO,TU,WE,TH,FR,SA
especifica uma recorrência nos dias da semana selecionados.
- O formato
O exemplo a seguir especifica uma janela de manutenção de seis horas entre a 1h e 07:00 (UTC) às quartas-feiras, sábados e domingos. O dia 1o de janeiro de 2023 a data é ignorada.
// PATCH https://composer.googleapis.com/v1/projects/example-project/
// locations/us-central1/environments/example-environment?updateMask=
// config.maintenanceWindow
{
"config": {
"maintenanceWindow": {
"startTime": "2023-01-01T01:00:00Z",
"endTime": "2023-01-01T07:00:00Z",
"recurrence": "FREQ=WEEKLY;BYDAY=SU,WE,SA"
}
}
}
Terraform
O bloco maintenance_window
especifica as janelas de manutenção para seu
ambiente:
resource "google_composer_environment" "example" {
provider = google-beta
name = "ENVIRONMENT_NAME"
region = "LOCATION"
config {
maintenance_window {
start_time = "DATETIME_START"
end_time = "DATETIME_END"
recurrence = "MAINTENANCE_RECURRENCE"
}
}
}
Substitua:
ENVIRONMENT_NAME
pelo nome do ambienteLOCATION
pela região em que o ambiente está localizado;DATETIME_START
pela data e hora de início no formato de entrada de data/hora. Somente a hora especificada do dia é usada, a data especificada é ignorada.DATETIME_END
pela data e hora de término no formato de entrada de data/hora. Somente a hora especificada do dia é usada, a data especificada é ignorada. A data e hora especificadas precisam ser posteriores à data de início.MAINTENANCE_RECURRENCE
por um RFC 5545 RRULE para a recorrência de janelas de manutenção. O Cloud Composer é compatível com dois formatos:- O formato
FREQ=DAILY
especifica uma recorrência diária. - O formato
FREQ=WEEKLY;BYDAY=SU,MO,TU,WE,TH,FR,SA
especifica uma recorrência nos dias da semana selecionados.
- O formato
O exemplo a seguir especifica uma janela de manutenção de seis horas entre a 1h e 07:00 (UTC) às quartas-feiras, aos sábados e aos domingos. O dia 1o de janeiro de 2023 a data é ignorada.
resource "google_composer_environment" "example" {
provider = google-beta
name = "example-environment"
region = "us-central1"
config {
maintenance_window {
start_time = "2023-01-01T01:00:00Z"
end_time = "2023-01-01T07:00:00Z"
recurrence = "FREQ=WEEKLY;BYDAY=SU,WE,SA"
}
}
}