AnalyticDB:Use DMS to schedule AnalyticDB for MySQL jobs

CREATE DATABASE adb_test;

CREATE TABLE orders (
  order_id     BIGINT        NOT NULL COMMENT 'Order ID',
  order_status VARCHAR(10)   NOT NULL COMMENT 'Order status',
  total_price  DECIMAL(15,2) NOT NULL COMMENT 'Total price',
  order_date   DATE          NOT NULL COMMENT 'Order date',
  PRIMARY KEY (order_id)
);

CREATE TABLE finish_orders (
  order_id    BIGINT        NOT NULL COMMENT 'Order ID',
  total_price DECIMAL(15,2) NOT NULL COMMENT 'Total price',
  order_date  DATE          NOT NULL COMMENT 'Order date',
  PRIMARY KEY (order_id)
);

CREATE TABLE large_finish_orders (
  order_id    BIGINT        NOT NULL COMMENT 'Order ID',
  total_price DECIMAL(15,2) NOT NULL COMMENT 'Total price',
  order_date  DATE          NOT NULL COMMENT 'Order date',
  PRIMARY KEY (order_id)
);

Etapa 1: Crie um fluxo de tarefas

1. Faça logon no console do AnalyticDB for MySQL. No canto superior esquerdo, selecione uma região. No painel de navegação à esquerda, clique em Clusters e, em seguida, clique no ID do cluster desejado.

2. No painel de navegação à esquerda, clique em Job Scheduling.

   Se esta for a primeira vez que você acessa um banco de dados AnalyticDB for MySQL pelo console do DMS, insira suas credenciais de logon do banco de dados. Para mais detalhes, consulte Fazer logon em um banco de dados . Caso já tenha feito logon anteriormente em um cluster do AnalyticDB for MySQL nos modos Flexible Management ou Stable Change sem marcar a opção Remember Password , uma solicitação de senha aparecerá ao abrir o console do DMS. Para detalhes sobre os modos de controle, consulte Modos de controle .

3. Passe o mouse sobre > All Features.

4. Escolha Data+AI > Data Development > Task Orchestration.

5. Na página Task orchestration, clique em Create Task Flow.

6. Na caixa de diálogo New Task Flow, insira um Task Flow Name (por exemplo, Order Filtering) e uma Description opcional, depois clique em OK.

Etapa 2: Adicione nós de tarefa

Na página de orquestração de tarefas Order Filtering, adicione dois nós Single Instance SQL e conecte-os.

Etapa 3: Agende e publique

1. Na seção Task Flow Information, abaixo da tela, ative a chave Enable Scheduling e configure os parâmetros de agendamento.

   Este exemplo agenda a tarefa para execução diária às 01:00, de 1º de fevereiro de 2023 a 28 de fevereiro de 2023. Ajuste o cronograma conforme suas necessidades. Para todos os parâmetros de agendamento disponíveis, consulte Configurar agendamento .

2. No canto superior esquerdo da tela, clique em Publish.

3. Na caixa de diálogo Publish, insira quaisquer Remarks e clique em Publish.

4. Verifique se o fluxo de tarefas foi publicado: clique em Go to O&M no canto superior direito e verifique o parâmetro Released.

   Valor	Significado
   Published	O fluxo de tarefas está ativo e executará conforme o agendamento
   Not published	O fluxo de tarefas não foi publicado com êxito

Visualize o histórico e o status das execuções

No console de O&M, visualize o histórico de execução de cada fluxo de tarefas. Use essas informações para identificar execuções que falharam ou demoraram mais do que o esperado.

Trate falhas de tarefas

Quando uma tarefa falha, o console de O&M do DMS oferece operações como pausa, parada e reexecução. Para reexecutar ou tentar novamente um fluxo de tarefas, acesse o console de O&M, localize a execução com falha e escolha a ação apropriada.

Configure notificações

Para receber alertas quando uma tarefa for concluída com sucesso ou falhar, configure as notificações nas configurações do fluxo de tarefas. O DMS suporta os seguintes métodos de notificação:

• DingTalk

• Mensagem de texto

• E-mail