DataWorks:Nó KingbaseES

Contexto

O KingbaseES é um sistema de gerenciamento de banco de dados relacional (RDBMS) de grande escala compatível com o padrão SQL. É adequado para aplicações corporativas que processam grandes volumes de dados e exigem alta concorrência e alta disponibilidade. Para mais informações, visite o site oficial do KingbaseES.

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.

• Fonte de dados KingbaseES criada.

  Adicione seu banco de dados KingbaseES como uma source de dados KingbaseES no DataWorks antes de acessar os dados. Para criar uma source de dados, consulte Data source management. Para mais informações sobre como usar uma source de dados KingbaseES no DataWorks, consulte KingbaseES data source.

  Nota

  Os nós KingbaseES suportam apenas fontes de dados KingbaseES criadas com uma string de conexão JDBC.

• Conexão de rede estabelecida entre a fonte de dados e um grupo de recursos.

  Certifique-se de que a fonte de dados desejada esteja conectada ao grupo de recursos que você pretende utilizar. Para mais informações sobre como configure 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 desenvolvimento de tarefas adicionado ao workspace de destino e com a função Development ou Workspace Administrator atribuída (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.

Limitações

Este recurso está disponí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 o nó KingbaseES

1. Faça login no console do DataWorks. Na região de destino, clique em Data Development and O&M > Data Development no painel de navegação à esquerda. Selecione um workspace na lista suspensa e clique em Go to Data Development.

2. Clique com o botão direito no fluxo de trabalho de destino e escolha Create Node > Database > KingbaseES.

3. Na caixa de diálogo Create Node, insira um Name para o nó e clique em OK. Após criar o nó, desenvolva e configure tarefas nele.

Etapa 2: Desenvolver uma tarefa KingbaseES

(Opcional) Selecionar uma source de dados KingbaseES

Se você criou várias fontes de dados KingbaseES no workspace, selecione a fonte desejada na página de edição do nó KingbaseES. Caso exista apenas uma source de dados KingbaseES, o DataWorks a utilizará por padrão.

Escrever código SQL: Exemplo simples

No editor de código do nó KingbaseES, escreva o código SQL da tarefa. Código de exemplo:

SELECT * FROM usertablename;

Escrever código SQL: Usar parâmetros de agendamento

O DataWorks fornece o Scheduling Parameter, que permite passar parâmetros dinamicamente em cenários de agendamento periódico. Defina variáveis no código da tarefa usando o formato ${variable_name}. Em seguida, atribua valores a essas variáveis em Properties > Scheduling Parameter no painel de navegação à direita da página de edição do nó. Para mais informações sobre formatos suportados e configuração de parâmetros de agendamento, consulte Supported formats of scheduling parameters e Configure and use scheduling parameters.

Código de exemplo:

SELECT '${var}'; -- An example of using a scheduling parameter.

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.

Etapa 4: Testar o código da tarefa

Execute as operações de teste abaixo conforme necessário para verifique se a tarefa se comporta conforme o esperado.

1. (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âmetros de agendamento, atribua valores a elas aqui para teste. Para mais informações sobre a lógica de atribuição de parâmetros, consulte Task debugging process.

2. Salve e execute o código da tarefa.

   Clique no ícone na barra de ferramentas para salve o código da tarefa. Em seguida, clique no ícone para execute a tarefa.

3. (Opcional) Realize testes de fumaça (smoke testing).

   Para execute testes de fumaça no ambiente de desenvolvimento e verifique se a tarefa agendada do nó roda 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 configure a tarefa do nó, envie-a e publique-a. Depois de publicada, o nó será executado periodicamente com base na configuração de agendamento.

1. Clique no ícone na barra de ferramentas para salve o nó.

2. Clique no ícone na barra de ferramentas para envie 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.

   Nota

   • Configure 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 envie 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 envie e publicar uma tarefa, ela é executada periodicamente com base na configuração do nó. Clique em O&M no canto superior direito da página de edição do nó para acesse o Operation Center e visualize o status de agendamento e execução da tarefa agendada. Para mais informações, consulte Managing Scheduled Tasks.