Microservices Engine:Gerenciamento de tarefas

Criar uma tarefa

1. Acesse o console do MSE SchedulerX.

2. Acesse o console do EDAS.

3. No painel de navegação à esquerda, escolha Task Scheduling e selecione a região e o Namespace onde deseja criar a tarefa.

4. No painel de navegação à esquerda, clique em Task Management e selecione a região e o Namespace da tarefa.

5. Clique em Add Task. Na etapa Basic Configuration, defina as configurações da tarefa e clique em Next.

   A tabela a seguir descreve os parâmetros de configuração básica.

   Parâmetro	Descrição
   Nome da tarefa	Nome personalizado para a tarefa.
   Description	Breve descrição para identificar a tarefa nos resultados de busca.
   ID do aplicativo	Grupo de aplicativos ao qual a tarefa pertence. Selecione um grupo na lista suspensa.
   Tipo de tarefa	Linguagem ou ambiente de execução da tarefa. Os tipos suportados são Java, XXL-JOB, SpringSchedule, Golang, script task, Http e DataWorks. Se você selecionar script task, escolha uma linguagem de script: shell, python ou go. Em seguida, escreva o script da tarefa no editor fornecido.
   Caminho completo da classe	Nota Este parâmetro aparece apenas quando o Tipo de tarefa está definido como Java. Nome totalmente qualificado da classe JobProcessor, como xxx.xxx.xxx.HelloProcessor.
   Modo de execução	Define como a tarefa é executada. Os seguintes modos são suportados: stand-alone operation: Executa em um único worker, selecionado aleatoriamente. broadcast run: Executa simultaneamente em todos os workers e só termina após a conclusão de todos. Visual MapReduce: Modelo Map com uma lista visual de subtarefas. Suporta até 300 subtarefas. A edição Professional suporta até 1.000 subtarefas e permite buscar subtarefas por palavra-chave de negócio. MapReduce: Modelo MapReduce padrão que suporta processamento paralelo para um grande número de subtarefas. Fornece apenas informações resumidas das execuções. Recomendado para tarefas com até 1 milhão de subtarefas. shard run: Semelhante ao modelo elastic-job, permite configurar parâmetros de sharding para distribuir shards uniformemente entre vários clientes. Este modo suporta múltiplas linguagens. Nota As configurações avançadas variam conforme o modo de execução selecionado.
   Parâmetros da tarefa	String arbitrária acessível pelo contexto da tarefa durante a execução.

   A tabela a seguir descreve os parâmetros de configuração avançada.

   Parâmetro	Modos de execução aplicáveis	Descrição	Padrão
   Tentativas de nova execução após falha	Todos os modos	Número de vezes que o sistema tenta executar automaticamente a tarefa após uma falha. Nota Se um worker em execução for reiniciado, o status da tarefa muda para falha. Configure este parâmetro para reexecutar a tarefa imediatamente.	0
   Intervalo entre tentativas após falha	Todos os modos	Intervalo entre as novas tentativas. Unidade: segundos.	30
   Concorrência da tarefa	Todos os modos	Número máximo de instâncias da mesma tarefa que podem ser executadas simultaneamente. O valor 1 impede execuções sobrepostas.	1
   Estratégia de limpeza	Todos os modos	Política de limpeza do histórico de execução da tarefa.	Manter últimas N entradas
   Número de registros a reter	Todos os modos	Quantidade de registros de execução da tarefa a serem mantidos.	300 registros
   Concorrência de subtarefas por máquina	Visual MapReduce MapReduce shard run	Em modelos distribuídos, define quantas subtarefas um único worker pode processar simultaneamente. Aumente este valor para acelerar a execução ou diminua-o se os sistemas downstream ou bancos de dados não suportarem a carga.	5
   Tentativas de nova execução de subtarefa após falha	Visual MapReduce MapReduce shard run	Em modelos distribuídos, define quantas vezes o sistema tenta reexecutar automaticamente uma subtarefa com falha.	0
   Intervalo entre tentativas de subtarefa após falha	Visual MapReduce MapReduce shard run	Em modelos distribuídos, define o intervalo entre as novas tentativas de subtarefas. Unidade: segundos.	0
   Estratégia de failover de subtarefa	Visual MapReduce MapReduce shard run	Quando ativado, subtarefas com falha são redistribuídas para outros workers. Esse processo pode fazer com que uma subtarefa seja executada mais de uma vez, portanto, seu código deve ser idempotente. Nota Requer cliente v1.8.13 ou posterior.
   Nó mestre participa da execução	Visual MapReduce MapReduce shard run	Define se o nó mestre também executa subtarefas. É necessário ter pelo menos dois workers online. Se houver um número muito grande de subtarefas, recomenda-se desativar este parâmetro. Nota Requer cliente v1.8.13 ou posterior.
   Método de distribuição de subtarefas	Visual MapReduce MapReduce shard run	push model: Distribui subtarefas uniformemente entre os workers. pull model: Cada worker busca ativamente as subtarefas. Isso evita o efeito do "elo mais fraco". Durante o processo de pull, todas as subtarefas ficam em cache no nó mestre, o que pode consumir muita memória. Recomendado para tarefas com no máximo 10.000 subtarefas.	push model
   Política de distribuição	Visual MapReduce MapReduce	Política de distribuição das subtarefas. Por padrão, o sistema distribui as subtarefas entre os nós em round-robin. polling scheme: Atribui uma parte igual de subtarefas a cada worker. Use quando as subtarefas tiverem tempos de processamento semelhantes. Load-based strategy: O nó mestre detecta a carga dos workers e distribui as subtarefas de acordo. Use quando o tempo de processamento variar entre subtarefas ou workers. Nota Requer cliente v1.10.14 ou posterior.
   Taxa de distribuição	Visual MapReduce MapReduce	Velocidade com que as subtarefas são distribuídas. Especifique o número de subtarefas a distribuir por segundo ou por minuto.
   Tamanho do pull por solicitação (apenas pull model)	Visual MapReduce MapReduce shard run	Número de subtarefas que um worker (nó escravo) busca do nó mestre em uma única solicitação.	5
   Capacidade da fila de subtarefas (apenas pull model)	Visual MapReduce MapReduce shard run	Tamanho da fila de cache de subtarefas em cada worker (nó escravo).	10
   Concorrência global de subtarefas (apenas pull model)	Visual MapReduce MapReduce shard run	No modelo pull distribuído, define um limite global para o número de subtarefas simultâneas, servindo como limitador de taxa.	1.000

6. Na etapa Timing Configuration, defina as configurações de agendamento e os parâmetros avançados e clique em Next.

   A tabela a seguir descreve os parâmetros de agendamento.

   Parâmetro	Descrição
   Tipo de tempo	none: Sem agendamento. Tarefas geralmente acionadas por um fluxo de trabalho. cron: Uma expressão cron. api: Acionada por chamada de API. fixed_rate: Intervalo fixo. second_delay: Atraso fixo em segundos. onetime: Tarefa única. unix cron: Expressão cron estilo Unix.
   Expressão Cron (apenas para tipo de tempo cron)	Insira uma expressão cron. Escreva a expressão diretamente ou use uma ferramenta para gerá-la e validá-la.
   Frequência fixa (apenas para tipo de tempo fixed_rate)	Insira uma frequência fixa em segundos. O valor deve ser maior que 60. Por exemplo, o valor 200 agenda a tarefa a cada 200 segundos.
   Atraso fixo (apenas para tipo de tempo second_delay)	Insira um atraso fixo em segundos. Valores válidos variam de 1 a 60. Por exemplo, 5 aciona a tarefa após um atraso de 5 segundos.
   Horário agendado (apenas para tipo de tempo onetime)	Insira o horário de execução agendado da tarefa. Exemplo: 2023-7-13 00:00:00.
   Expressão cron Unix (apenas para tipo de tempo unix cron)	Insira uma expressão cron estilo Unix.

   A tabela a seguir descreve os parâmetros de configuração avançada.

   Parâmetro	Descrição
   Deslocamento de tempo	Diferença entre o timestamp dos dados e o horário do agendamento. Recupere esse valor do contexto de agendamento.
   Fuso horário	Selecione um fuso horário conforme sua necessidade. Escolha um fuso horário comum de país/região ou um deslocamento GMT padrão.

7. Na etapa Notification Configuration, configure os parâmetros de alerta e os contatos e clique em Complete.

   Esta etapa inclui várias configurações de alerta: Timeout alarm, Timeout termination, Success notification, Failure alarm e No available machine alarm. Defina os destinatários das notificações selecionando Application group contact ou Custom.

   Notification Channels and Contacts atualmente suporta Application Group Contacts e Custom.

   • Application group contact

     Todos os contatos do grupo de aplicativos recebem as notificações.

   • Custom

     No modo personalizado, especifique os destinatários por Contact group ou Contact.

     • Contact group

       Todos os contatos do grupo selecionado recebem as notificações. Para mais informações sobre como criar um grupo de contatos, consulte Contatos de notificação.

     • Contact

       1. Para adicionar contatos de notificação, clique em Add Contact e depois em Go to Create Contact. O sistema envia notificações para todos os contatos adicionados.

       2. Na caixa de diálogo exibida, clique em New Contact e insira as informações do contato.

       As informações incluem Name (obrigatório), Mobile, Email, webhook e Contact Group.

8. Retorne à página Task Management para verificar se a tarefa foi criada com as configurações especificadas.

   Nota

   As tarefas são ativadas por padrão após a criação. Desative e reative uma tarefa conforme suas necessidades de negócio. Para mais informações, consulte Ativar e desativar tarefas agendadas.

Editar tarefa

1. Na página Tasks, clique em Edit na coluna Actions da tarefa desejada.

2. No painel Edit, ajuste as configurações básicas, de agendamento e de notificação.

   Nota

   Não é possível modificar o ID do aplicativo ou o tipo de tarefa. As regras de configuração para os demais parâmetros seguem o mesmo padrão da criação de tarefas.

Executar uma tarefa agendada

Na página Tasks, clique em Run once na coluna Actions para executar a tarefa imediatamente.

Ativar ou desativar tarefas

Copiar uma tarefa agendada

Na página Tasks, na coluna Actions da tarefa alvo, clique em More > Copy. Isso copia a configuração da tarefa, permitindo editá-la para criar um novo agendamento.

Reprocessar uma tarefa

Se precisar reexecutar uma tarefa referente a um período passado devido a mudanças no negócio, como adicionar um novo campo a um banco de dados ou corrigir erros em dados históricos, utilize o recurso de reprocessamento (backfill).

Caso os dados de uma execução anterior estejam incorretos ou ausentes, execute um backfill para recuperar as informações corretas.

1. Acesse o console do MSE SchedulerX.

2. Na página Task Management, na coluna Actions da tarefa desejada, clique em More > Backfill Task.

3. No painel Backfill Task, defina a start and end date e o data timestamp e clique em OK.

   • Start and end date: Intervalo de datas para o reprocessamento.

   • Data timestamp: Define o horário do dia para cada instância de backfill gerada dentro do intervalo de datas.

   Exemplo de configuração de backfill:

   • Hora atual: 2019-01-01 10:00:00.

   • Data de início e fim: 2018-10-01 a 2018-10-07. Por padrão, o intervalo vai de 00:00:00 em 2018-10-01 até 23:59:59 em 2018-10-07.

   • Timestamp dos dados: 11:11:11.

   O backfill gera sete instâncias de tarefa.

   ID	Horário de agendamento	Timestamp dos dados
   1	2019-01-01 10:00:00	2018-10-01 11:11:11
   2	2019-01-01 10:00:00	2018-10-02 11:11:11
   3	2019-01-01 10:00:00	2018-10-03 11:11:11
   4	2019-01-01 10:00:00	2018-10-04 11:11:11
   5	2019-01-01 10:00:00	2018-10-05 11:11:11
   6	2019-01-01 10:00:00	2018-10-06 11:11:11
   7	2019-01-01 10:00:00	2018-10-07 11:11:11

Histórico de execução e registros de operação

• Visualizar histórico de execução: Na página Task Management, clique em More>History na coluna Actions da tarefa alvo para acessar seu histórico. Na página Task Instance History, filtre registros por critérios como status, ID do aplicativo e data, e marque a caixa Include Workflows. A tabela de histórico apresenta colunas como ID/Nome da Tarefa, Tipo de Tarefa/Método de Execução, ID da Instância/ID da Instância do Processo, ID do Aplicativo, Hora de Início, Hora de Término e Operador. A coluna Actions oferece links para Details, Logs e More. Uma mensagem no topo da página indica que a Edição Standard permite visualizar apenas 30 registros, enquanto a Edição Professional suporta 300 registros.

• Visualizar registros de operação: Na página Task Management, clique em More > Operation Records na coluna Actions da tarefa alvo para consultar as operações de gerenciamento realizadas. A página Operation Records permite filtrar por Type e Task ID. A tabela de resultados exibe as colunas Task ID, Operation Time, Operation Type, Operator, Extensions e Actions. Clique em View para ver os detalhes da operação.

Excluir uma tarefa

1. Na página Tasks, clique em More > Delete na coluna Actions da tarefa desejada.

2. Na caixa de diálogo de confirmação, clique em Confirm.

Importar ou exportar tarefas

1. Na página Tasks, selecione um aplicativo da Edição Professional.

   Escolha o aplicativo na lista suspensa All Applications no topo da página.

2. Clique em Import task ou Export tasks.