SchedulerX:Gerenciamento de tarefas

Criar uma tarefa

1. Faça login no console do SchedulerX.

2. Na barra de navegação superior, selecione uma região.

3. No painel de navegação à esquerda, selecione task management.

4. Na página , selecione o namespace e clique em Create Task. Na página do assistente Basic Configuration, configure os parâmetros da tarefa e clique em Next.

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

   Parâmetro	Descrição
   Name	Um nome personalizado para a tarefa.
   Description	Uma breve descrição para facilitar a localização e o gerenciamento da tarefa.
   Application ID	O grupo de aplicativos ao qual a tarefa pertence. Selecione um grupo de aplicativos na lista suspensa.
   Job Type	A linguagem de programação usada para implementar a tarefa. Os tipos suportados incluem Java, XXL-JOB, SpringSchedule, Golang, script task, Http e DataWorks. Se selecionar script task, selecione também uma linguagem de script (shell, python ou go) e escreva o script da tarefa no editor.
   Class full path	Nota Este parâmetro está disponível apenas se o Job type for Java. O caminho completo do JobProcessor, por exemplo, xxx.xxx.xxx.HelloProcessor.
   Execution Mode	O modo de execução da tarefa. Modos suportados: Standalone: Executa a tarefa em um worker selecionado aleatoriamente. broadcast run: Executa a tarefa simultaneamente em todos os workers disponíveis e aguarda a conclusão. Visual MapReduce: Um modelo Map com uma lista visual de subtarefas. Permite executar até 300 subtarefas. A Professional Edition suporta até 1.000 subtarefas e permite consultar subtarefas por palavra-chave de negócio. MapReduce: Um modelo MapReduce padrão que suporta muitas subtarefas em paralelo. Permite consultar apenas informações de resumo das subtarefas. Recomendado para até 1.000.000 de subtarefas. shard run: Semelhante ao modelo elastic-job. Configure parâmetros de sharding para distribuir shards uniformemente entre vários workers. Suporta várias linguagens de programação. Nota Os parâmetros nas configurações avançadas variam de acordo com o Execution Mode selecionado.
   Job Parameters	Uma string arbitrária que pode ser recuperada do contexto em tempo de execução.

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

   Parâmetro	Modo de execução aplicável	Descrição	Padrão
   Tentativas de repetição da tarefa em caso de falha	Geral	O número de tentativas automáticas em caso de falha da tarefa. Nota A tarefa falha se o worker for reiniciado. Use este parâmetro para reexecutá-la imediatamente.	0
   Intervalo entre tentativas de repetição da tarefa em caso de falha	Geral	O intervalo entre as tentativas. Unidade: segundos.	30
   Simultaneidade da tarefa	Geral	O número de instâncias simultâneas permitidas para a tarefa. O valor 1 indica que as instâncias não podem ser executadas simultaneamente.	1
   Política de limpeza	Geral	A política de limpeza para o histórico de execução da tarefa.	Manter os últimos N registros
   Número de registros a serem mantidos	Geral	O número de registros históricos de execução a serem mantidos.	300
   Simultaneidade de subtarefas por worker	Visual MapReduce MapReduce shard run	Em um modelo distribuído, especifica o número de subtarefas que um único worker pode processar simultaneamente. Aumente esse valor para acelerar a execução. Se os serviços ou bancos de dados downstream não suportarem a carga, diminua o valor.	5
   Tentativas de repetição de subtarefas em caso de falha	Visual MapReduce MapReduce shard run	Em um modelo distribuído, especifica o número de vezes que uma subtarefa é repetida automaticamente em caso de falha.	0
   Intervalo de repetição de subtarefas em caso de falha	Visual MapReduce MapReduce shard run	Em um modelo distribuído, especifica o intervalo entre as repetições automáticas para uma subtarefa com falha. Unidade: segundos.	0
   Política de failover de subtarefas	Visual MapReduce MapReduce shard run	Especifica se as subtarefas devem ser redistribuídas para outros workers caso o worker em execução fique offline. Se ativado, as subtarefas poderão ser executadas mais de uma vez durante um failover. Certifique-se de que o código seja idempotente. Nota Este recurso requer a versão 1.8.13 ou posterior do worker.
   Participação do nó mestre na execução	Visual MapReduce MapReduce shard run	Especifica se o nó mestre também executa subtarefas. Requer pelo menos dois workers online. Recomendamos desativar este parâmetro quando o número de subtarefas for muito grande. Nota Este recurso requer a versão 1.8.13 ou posterior do worker.
   Modo de despacho de subtarefas	Visual MapReduce MapReduce shard run	push model: Distribui as subtarefas uniformemente para cada worker. pull model: Cada worker puxa as subtarefas, evitando o efeito do "worker mais lento". Todas as subtarefas são armazenadas em cache no nó mestre durante esse processo, o que aumenta a pressão sobre a memória. Recomendado para até 10.000 subtarefas.	push model
   Estratégia de despacho	Visual MapReduce MapReduce	A estratégia para despachar subtarefas. Por padrão, o despacho para os workers ocorre de forma round-robin. Round-robin strategy: Distribui as subtarefas uniformemente para cada worker. Adequada para cenários em que cada subtarefa leva aproximadamente o mesmo tempo de processamento. Load-optimal strategy: O nó mestre detecta dinamicamente a carga em cada worker. Adequada para cenários em que os tempos de processamento variam significativamente entre subtarefas ou workers. Nota Este recurso requer a versão 1.10.14 ou posterior do worker.
   Taxa de despacho	Visual MapReduce MapReduce	A taxa de despacho das subtarefas. Especifique o número de subtarefas despachadas por segundo ou por minuto.
   Número de subtarefas por pull (apenas modelo pull)	Visual MapReduce MapReduce shard run	O número de subtarefas que um worker puxa do nó mestre em uma única solicitação.	5
   Capacidade da fila de subtarefas (apenas modelo pull)	Visual MapReduce MapReduce shard run	O tamanho da fila de cache de subtarefas em um worker.	10
   Simultaneidade global de subtarefas (apenas modelo pull)	Visual MapReduce MapReduce shard run	O modelo pull suporta um limite global de simultaneidade para subtarefas, útil para limitação de taxa.	1.000

5. Na página do assistente Schedule Configuration, defina os parâmetros de agendamento e de configuração avançada e clique em Next.

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

   Parâmetro	Descrição
   Time Type	none: Não agendado. A tarefa geralmente é acionada por um workflow. cron: A tarefa é acionada com base em uma expressão CRON. api: A tarefa é acionada por uma chamada de API. fixed_rate: A tarefa é acionada em frequência fixa. second_delay: A tarefa é acionada após um atraso fixo em segundos. onetime: A tarefa é executada apenas uma vez. unix cron: A tarefa é acionada com base em uma expressão CRON no formato UNIX padrão.
   Cron Expression (disponível apenas se o Time type for cron)	Insira uma expressão CRON. Escreva a expressão manualmente ou use uma ferramenta para gerá-la e validá-la.
   Frequência fixa (disponível apenas se o Time type for fixed_rate)	Insira um intervalo fixo em segundos. O valor deve ser 60 ou superior. Por exemplo, o valor 200 significa que a tarefa é agendada a cada 200 segundos.
   Atraso fixo (disponível apenas se o Time type for second_delay)	Insira um atraso fixo em segundos. O valor deve ser um número inteiro de 1 a 60. Por exemplo, o valor 5 significa que a tarefa é acionada após um atraso de 5 segundos.
   Horário de agendamento (disponível apenas se o Time type for onetime)	Insira o horário específico para executar a tarefa, por exemplo, 2023-7-13 00:00:00.
   expressão unix cron (disponível apenas se o Time type for unix cron)	Insira uma expressão CRON no formato UNIX padrão.

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

   Parâmetro	Descrição
   Deslocamento de tempo	O deslocamento do tempo de dados em relação ao tempo agendado. Esse valor pode ser recuperado do contexto em tempo de execução.
   Time Zone	Selecione um fuso horário conforme necessário. Escolha entre países e regiões comuns ou use um formato GMT padrão.

6. Na página do assistente Notification Configuration, defina os parâmetros de alerta e os contatos e clique em Finish.

   Os parâmetros de alerta incluem as opções Timeout Alert, Timeout (em segundos), Kill on Timeout, Success Notification, Failure Alert, Consecutive Failures e No Available Worker Alert. Em Notification channel and contact, selecione Application group contact ou Custom.

   Em Notification channel and contact, selecione Application group contact ou Custom.

   • Application group contact

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

   • Custom

     Especifique um Contact Group ou um Contact individual para receber notificações.

     • Contact Group

       Todos os contatos no grupo de contatos selecionado recebem notificações. Para mais informações sobre como criar um grupo de contatos, consulte Create a notification contact or a contact group.

     • Contact

       1. Adicione os contatos que receberão as notificações. É possível adicionar vários contatos. Após clicar em Add contact, clique em Go to create contact.

       Na seção Notification channel and contact, selecione Custom, marque a caixa de seleção webhook para Notification channel e selecione Contact para Notification contact. Se a lista suspensa de contatos exibir No options, nenhum contato estará disponível.

       2. Na página exibida, clique em Create Contact e insira as informações de contato.

       As informações de contato incluem Name (obrigatório), Phone number, Email, webhook e Contact group.

7. Retorne à página task management para verificar se a tarefa foi criada e configurada corretamente.

   Nota

   Por padrão, as tarefas são ativadas após a criação. Desative-as e reative-as conforme necessário. Para mais informações, consulte Enable and disable a scheduled job.

Editar uma tarefa

1. Na página Task Management, localize a tarefa e clique em Edit na coluna Actions.

2. No painel Edit, configure as definições básicas, de agendamento e de alerta.

   Nota

   Não é possível modificar o Application ID e o tipo de tarefa. As configurações dos outros parâmetros seguem o mesmo padrão da criação de uma tarefa.

Executar uma tarefa

Na página Task Management, clique em Run Once na coluna Actions para executar a tarefa.

Ativar e desativar tarefas

Replicar tarefa

Na página Task Management, escolha More > Copy na coluna Actions da tarefa. Em seguida, edite a configuração da nova tarefa.

Reprocessar uma tarefa

Reexecute uma tarefa para repor dados de um período passado. Isso é útil quando os requisitos de negócio mudam, por exemplo, ao adicionar um novo campo a um banco de dados ou ao corrigir dados do mês anterior.

Se os dados de uma execução anterior da tarefa estiverem com erro ou ausentes, reexecute a tarefa com parâmetros específicos para reprocessar os dados daquele período.

1. Faça login no console do SchedulerX.

2. Na página Task Management, localize a tarefa, clique em More na coluna Actions e selecione Rebrush task.

3. No painel Rebrush task, defina a Start and end date e o Data time e clique em OK.

   • Start and end date: O intervalo de datas para reexecução da tarefa.

   • Data time: A hora do dia usada como horário lógico dos dados para cada dia no intervalo especificado.

   Por exemplo, considere a seguinte configuração:

   • A hora atual é 10:00:00 em 1 de janeiro de 2019.

   • A Start and end date está definida de 1 a 7 de outubro de 2018. Este intervalo abrange o período de 00:00:00 de 1 de outubro de 2018 a 23:59:59 de 7 de outubro de 2018.

   • O Data time está definido como 11:11:11.

   Neste cenário, a tarefa é reexecutada sete vezes, gerando sete novas instâncias.

   Nº	Horário de agendamento	Data time
   1	2019.1.1 10:00:00	2018.10.1 11:11:11
   2	2019.1.1 10:00:00	2018.10.2 11:11:11
   3	2019.1.1 10:00:00	2018.10.3 11:11:11
   4	2019.1.1 10:00:00	2018.10.4 11:11:11
   5	2019.1.1 10:00:00	2018.10.5 11:11:11
   6	2019.1.1 10:00:00	2018.10.6 11:11:11
   7	2019.1.1 10:00:00	2018.10.7 11:11:11

Registros de execução e operação

• Para visualizar os registros de execução, acesse a página Task Management, localize a tarefa e clique em More > Historical records na coluna Actions.

• Para visualizar os registros de operação, acesse a página Task Management, localize a tarefa e clique em More > Operation Record na coluna Actions. Na página Operation Record, filtre os registros por Type e Task ID. A tabela lista Task ID, Operation Time, Operation Type, Operator e Extensions. Para visualizar os detalhes de um registro, clique em View na coluna Operation.

Excluir uma tarefa

1. Na página Task Management, localize a tarefa que deseja excluir e escolha More > Delete na coluna Actions.

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

Importar ou exportar tarefas

1. Na página Task Management, selecione um aplicativo da Professional Edition.

2. Clique em Import Jobs ou Export Tasks.