O DataWorks oferece nós DRDS para desenvolver e agendar periodicamente tarefas DRDS, além de integrá-las a outros tipos de tarefa. Este tópico descreve como usar um nó DRDS para desenvolver tarefas.
Informações básicas
O PolarDB for Xscale (PolarDB-X), anteriormente conhecido como DRDS, é um service de banco de dados distribuído. Ele permite escalar horizontalmente um banco de dados relacional para um sistema distribuído com suporte ao armazenamento e acesso de grandes volumes de dados. O PolarDB-X preserva as funcionalidades originais dos bancos de dados relacionais, como o MySQL. Para mais informações, consulte Overview.
Pré-requisitos
-
Fluxo de negócios criado.
O Data Studio executa operações de desenvolvimento específicas do mecanismo com base em fluxos de negócios. Crie um fluxo de negócios antes de criar um nó. Para mais informações, consulte Create a business flow.
-
Source de dados DRDS adicionada.
Adicione seu banco de dados PolarDB-X ao DataWorks como uma source de dados DRDS antes de usá-la para acessar os dados do banco. Para saber como adicionar uma source de dados, consulte Add and manage data sources. Para detalhes sobre o uso de uma source de dados DRDS no DataWorks, consulte DRDS (PolarDB-X 1.0) data source.
NotaA criação de nós DRDS é compatível apenas com sources de dados DRDS adicionadas ao DataWorks no modo de string de conexão Java Database Connectivity (JDBC).
-
Conexão de rede estabelecida entre a source de dados e um grupo de recursos.
Certifique-se de que a source de dados desejada esteja conectada ao grupo de recursos que você pretende usar. Para mais informações sobre como configurar a conectividade de rede, consulte Establish a network connection between a resource group and a data source.
(Opcional; obrigatório para usuários do Resource Access Management (RAM)) Usuário RAM usado para o desenvolvimento de tarefas adicionado ao workspace de destino e com a função Development ou Workspace Administrator atribuída (esta última concede permissões amplas — atribua com cautela). Para mais informações sobre como adicionar membros e conceder permissões, consulte Add members to a workspace.
Limites
Este tipo de nó é compatível nas seguintes regiões: China (Hangzhou), China (Shanghai), China (Beijing), China (Shenzhen), China (Chengdu), China (Hong Kong), Singapore, Malaysia (Kuala Lumpur), Germany (Frankfurt), US (Silicon Valley) e US (Virginia).
Etapa 1: Criar um nó DRDS
-
Faça login no console do DataWorks. Na região de destino, clique em no painel de navegação à esquerda. Selecione um workspace na lista suspensa e clique em Go to Data Development.
Clique com o botão direito no fluxo de trabalho desejado e escolha .
Na caixa de diálogo Create Node, insira um Name para o nó e clique em OK. Após a criação, desenvolva e configure a tarefa no editor de nós.
Etapa 2: Desenvolver uma tarefa DRDS
(Opcional) Selecionar uma source de dados DRDS
Se o workspace tiver múltiplas sources de dados DRDS, selecione uma na lista suspensa Select Data Source, na parte superior da aba de configuração do nó, conforme sua necessidade de negócio. Caso haja apenas uma source de dados DRDS no workspace, ela será usada automaticamente para desenvolver as tarefas.
A criação de nós DRDS é compatível apenas com sources de dados DRDS adicionadas ao DataWorks no modo de string de conexão Java Database Connectivity (JDBC).
Desenvolver código SQL: Exemplo simples
No editor de código da aba de configuração do nó DRDS, escreva o código da tarefa. Código de exemplo:
SELECT * FROM usertablename;
Desenvolver código SQL: Usar parâmetros de agendamento
O DataWorks disponibiliza o recurso Scheduling Parameter para passar parâmetros dinamicamente ao código em cenários de agendamento periódico. Em uma tarefa de nó, defina uma variável no código usando o formato ${variable_name}. Em seguida, atribua um valor à variável na seção scheduling properties > Scheduling Parameter, na barra lateral direita da página de edição do nó. Para mais informações sobre os formatos compatíveis e detalhes de configuração, consulte Supported formats for scheduling parameters e Configure and use scheduling parameters.
Código de exemplo:
SELECT '${var}'; -- You can assign a specific scheduling parameter to the var variable.
Etapa 3: Configurar o agendamento da tarefa
Para executar a tarefa do nó periodicamente, clique em Scheduling no lado direito da página de edição do nó e defina as configurações de agendamento conforme necessário. Para mais informações, consulte Overview of task scheduling properties.
Configure o Rerun attribute e os Parent Nodes do nó antes de enviá-lo.
Etapa 4: Testar o código da tarefa
Execute as operações de teste abaixo conforme necessário para validar se a tarefa se comporta conforme o esperado.
-
(Opcional) Selecione um grupo de recursos e atribua valores personalizados aos parâmetros.
Clique no ícone
na barra de ferramentas. Na caixa de diálogo Parameter, selecione o grupo de recursos de agendamento para teste.Se o código da tarefa usar variáveis de parâmetro de agendamento, atribua valores a elas neste momento para fins de teste. Para mais detalhes sobre a lógica de atribuição de parâmetros, consulte Task debugging process.
-
Salve e execute o código da tarefa.
Clique no ícone
na barra de ferramentas para salvar o código da tarefa. Em seguida, clique no ícone
para executar a tarefa. -
(Opcional) Execute testes de fumaça (smoke testing).
Para executar testes de fumaça no ambiente de desenvolvimento e verificar se a tarefa agendada executa conforme o esperado, realize esses testes durante ou após o envio do nó. Para mais informações, consulte Perform smoke testing.
Etapa 5: Enviar e publicar a tarefa
Após configurar a tarefa do nó, envie-a e publique-a. Depois de publicada, a tarefa será executada periodicamente de acordo com sua configuração de agendamento.
Clique no ícone
na barra de ferramentas para salvar o nó.-
Clique no ícone
na barra de ferramentas para enviar a tarefa do nó.Na caixa de diálogo Submission, insira uma Change Description. Opcionalmente, escolha se deseja exigir revisão de código após o envio.
NotaConfigure o Rerun attribute e os Parent Nodes do nó antes de enviá-lo.
A revisão de código ajuda a garantir a qualidade e evita erros causados pela publicação direta de código não revisado em produção. Se a revisão de código estiver ativada, os revisores deverão aprovar o código do nó enviado antes da publicação. Para mais informações, consulte Code review.
Se você usar um workspace no modo padrão, após enviar a tarefa com sucesso, clique em Publish no canto superior direito da página de edição do nó para implantar a tarefa no ambiente de produção. Para mais informações, consulte Publish a task.
Próximas etapas
Operações da tarefa: Após o envio e a publicação, a tarefa executa periodicamente conforme a configuração do nó. Clique em O&M no canto superior direito da página de edição do nó para acessar o Operation Center e visualizar o status de agendamento e execução da tarefa agendada. Para mais informações, consulte Managing Scheduled Tasks.