Os nós do PolarDB for MySQL no DataWorks permitem desenvolver, agendar e integrar tarefas do PolarDB for MySQL. Este tópico descreve como desenvolver tarefas utilizando um nó do PolarDB for MySQL.
Informações de fundo
O PolarDB for MySQL é um banco de dados nativo da cloud de nova geração desenvolvido pela Alibaba Cloud. Sua arquitetura desacopla computação e armazenamento, aproveitando a integração entre software e hardware. Esse design oferece um service de banco de dados altamente elástico, com alto desempenho, seguro, confiável e com capacidade massiva de armazenamento. O PolarDB for MySQL é totalmente compatível com os ecossistemas MySQL e PostgreSQL, além de apresentar alta compatibilidade com a sintaxe Oracle. Para mais informações, consulte What is PolarDB for MySQL?.
Pré-requisitos
-
O fluxo de negócios foi criado.
O Data Studio executa operações de desenvolvimento específicas do mecanismo com base em fluxos de negócios. Antes de criar um nó, crie primeiro um fluxo de negócios. Para mais informações, consulte Create a business flow.
-
Uma source de dados do PolarDB for MySQL foi criada.
Adicione seu banco de dados PolarDB for MySQL como uma source de dados no DataWorks para acessar seus dados. Para criar uma source de dados, consulte Add and manage data sources. Para mais detalhes sobre como utilizar uma source de dados do PolarDB for MySQL no DataWorks, consulte PolarDB data source.
NotaOs nós do PolarDB for MySQL suportam apenas sources de dados do PolarDB for MySQL criadas com uma string de conexão Java Database Connectivity (JDBC).
-
Uma conexão de rede foi estabelecida entre sua 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)) O usuário RAM utilizado para o desenvolvimento de tarefas foi adicionado ao workspace alvo e recebeu a função Development ou Workspace Administrator (que 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
Regiões suportadas: 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ó do PolarDB for MySQL
-
Faça login no console do DataWorks. Na região alvo, 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 alvo e escolha .
Na caixa de diálogo Create Node, insira um Name para o nó e clique em OK. Após a criação, utilize o nó para desenvolver e configurar sua tarefa.
Etapa 2: Desenvolver a tarefa do PolarDB for MySQL
(Opcional) Selecionar uma source de dados do PolarDB for MySQL
Caso existam múltiplas sources de dados do PolarDB for MySQL no seu workspace, selecione aquela que será usada na página de configuração do nó. Se houver apenas uma source de dados do PolarDB for MySQL, ela será utilizada por padrão.
Os nós do PolarDB for MySQL suportam apenas sources de dados do PolarDB for MySQL criadas com uma string de conexão Java Database Connectivity (JDBC).
Desenvolver código SQL: Exemplo simples
No editor de código do nó PolarDB for MySQL, escreva o código SQL a ser executado. O código abaixo serve como exemplo:
SELECT * FROM usertablename;
Desenvolver código SQL: Usar parâmetros de agendamento
O DataWorks oferece o recurso Scheduling Parameter, que consiste em variáveis dinâmicas para o código da sua tarefa agendada. Defina variáveis no código da tarefa usando o formato ${variable_name}. Em seguida, na aba Schedule no painel à direita, atribua valores a essas variáveis na seção Scheduling Parameter. Para mais informações sobre formatos suportados e configuração, consulte Supported formats of scheduling parameters e Configure and use scheduling parameters.
O código a seguir é um exemplo:
SELECT '${var}';
Etapa 3: Configurar o agendamento da tarefa
Para executar periodicamente a tarefa do nó, clique em Scheduling no lado direito da página de edição do nó e defina as configurações de agendamento conforme suas necessidades. Para mais informações, consulte Overview of task scheduling properties.
É necessário configurar o Rerun attribute e os Parent Nodes do nó antes de enviá-lo.
Etapa 4: Testar o código da tarefa
Realize as operações de teste abaixo conforme necessário para verificar 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 utilizar variáveis de parâmetro de agendamento, atribua valores a elas aqui 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 rodar testes de fumaça no ambiente de desenvolvimento e validar se a tarefa agendada do nó 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. Uma vez publicada, o nó será executado periodicamente com base na 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.
NotaÉ necessário configurar o Rerun attribute e os Parent Nodes do nó antes de poder 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, o código do nó enviado precisará ser aprovado pelos revisores antes da publicação. Para mais informações, consulte Code review.
Se estiver usando 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: Depois que uma tarefa é enviada e publicada, 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 acessar o Operation Center e visualizar o status de agendamento e execução da tarefa agendada. Para mais informações, consulte Managing Scheduled Tasks.