Nota
O acesso a esta página requer autorização. Pode tentar iniciar sessão ou alterar os diretórios.
O acesso a esta página requer autorização. Pode tentar alterar os diretórios.
As atividades são os blocos de construção que ajudam a criar fluxos de trabalho de dados de ponta a ponta no Microsoft Fabric. Pense neles como as tarefas que movem e transformam seus dados para atender às suas necessidades de negócios. Você pode usar uma atividade de cópia para mover dados do SQL Server para o Armazenamento de Blobs do Azure. Em seguida, você pode adicionar uma atividade de fluxo de dados ou atividade de bloco de anotações para processar e transformar esses dados antes de carregá-los no Azure Synapse Analytics para relatórios.
As atividades são agrupadas em fluxos de trabalho para atingir objetivos específicos. Por exemplo, você pode criar um pipeline que:
- Obtém dados de log de diferentes fontes
- Limpa e organiza esses dados
- Executa análises para encontrar insights
Agrupar suas atividades em um pipeline permite gerenciar todas essas etapas como uma unidade, em vez de lidar com cada atividade separadamente. Você pode implantar e agendar todo o pipeline de uma só vez, para ser executado sempre que precisar.
O Microsoft Fabric oferece três tipos de atividades:
- Atividades de movimentação de dados - Mover dados entre sistemas
- Atividades de transformação de dados - Processe e transforme seus dados
- Controle as atividades de fluxo - Gerencie como seu pipeline é executado
Atividades de movimento de dados
Essas atividades ajudam você a mover dados de um lugar para outro em seu pipeline.
| Atividade de movimento | Description |
|---|---|
| Copiar dados | Você pode copiar dados de qualquer fonte suportada para qualquer destino suportado. Consulte a visão geral sobre Conectores para saber o que está disponível. |
| Trabalho de cópia | Os trabalhos de cópia são um método simplificado para mover dados rapidamente. |
Se você precisar escolher entre diferentes opções de movimentação de dados, consulte o artigo do guia de decisão de movimentação de dados .
Atividades de transformação de dados
Estas atividades ajudam-no a processar e transformar os seus dados. Você pode usá-los individualmente ou encadeá-los juntamente com outras atividades.
Para obter mais informações, veja o artigo Data Transformation Activities (Atividades de Transformação de Dados).
| Atividade de transformação de dados | Ambiente de computação |
|---|---|
| Copiar dados | Gerenciador de computação do Microsoft Fabric |
| Fluxo de dados Gen2 | Gerenciador de computação do Microsoft Fabric |
| Excluir dados | Gerenciador de computação do Microsoft Fabric |
| Caderno de tecido | Clusters do Apache Spark gerenciados pelo Microsoft Fabric |
| Atividade do HDInsight | Clusters do Apache Spark gerenciados pelo Microsoft Fabric |
| Definição de trabalho do Spark | Clusters do Apache Spark gerenciados pelo Microsoft Fabric |
| Procedimento armazenado | SQL do Azure, Azure Synapse Analytics ou SQL Server |
| Script SQL | SQL do Azure, Azure Synapse Analytics ou SQL Server |
Atividades de controlo de fluxo
Essas atividades ajudam você a controlar como seu pipeline é executado:
| Atividade de controlo | Description |
|---|---|
| Append variável | Adicione um valor a uma variável de matriz existente. |
| Atividade de aprovação | Pausa a execução do pipeline e solicita aos revisores designados uma decisão para aprovar ou rejeitar. |
| Atividade do Azure Batch | Executa um script do Azure Batch. |
| Atividade do Azure Databricks | Executa um trabalho do Azure Databricks (Notebook, Jar, Python). |
| Atividade do Azure Machine Learning | Executa um trabalho do Azure Machine Learning. |
| Desativar atividade | Desativa outra atividade. |
| Fail | Faça com que a execução do pipeline falhe com uma mensagem de erro personalizada e um código de erro. |
| Filter | Aplique uma expressão de filtro a uma matriz de entrada. |
| ForEach | A atividade ForEach define um fluxo de controlo repetido no seu pipeline. Esta atividade é utilizada para percorrer uma coleção e executar atividades especificadas num loop. A implementação de ciclo desta atividade é semelhante à estrutura de ciclo Foreach nas linguagens de programação. |
| Atividade de funções | Executa uma função do Azure. |
| Obter metadados | A atividade GetMetadata pode ser usada para recuperar metadados de quaisquer dados em um pipeline do Data Factory ou Synapse. |
| Se condição | A condição "Se" pode ser utilizada para desviar o fluxo com base em uma condição que avalia como verdadeira ou falsa. A atividade Se Condição disponibiliza a mesma funcionalidade que as instruções “se” fornecem nas linguagens de programação. Avalia um conjunto de atividades quando a condição é avaliada como true e outro conjunto de atividades quando é avaliada como false. |
| Invocar pipeline | A atividade Executar pipeline permite que um pipeline do Data Factory ou Synapse invoque outro pipeline. |
| Atividade KQL | Executa um script KQL em uma instância de Kusto. |
| Atividade de manutenção do Lakehouse | Realizar manutenção rotineira de tabelas em um Lakehouse a partir de um pipeline da Microsoft Fabric. |
| Atividade de pesquisa | A atividade de Pesquisa pode ser utilizada para ler ou procurar registos/nomes de tabelas/valores em qualquer origem externa. Este resultado pode ser ainda utilizado como referência por atividades subsequentes. |
| Renovar a atividade Materialized Lake View | Refresca a vista materializada do lago numa casa do lago para refletir os dados mais recentes. |
| Atualizar a atividade do endpoint SQL | Atualiza um endpoint SQL do Lakehouse para refletir os dados mais recentes. |
| Definir variável | Defina o valor de uma variável existente. |
| Atividade do switch | Implementa uma expressão de switch que permite várias atividades subsequentes para cada resultado potencial da expressão. |
| Atividade das equipas | Publica uma mensagem em um canal do Teams ou bate-papo em grupo. |
| Até à atividade | Implementa um ciclo Do-Until, semelhante à estrutura de loop Do-Until nas linguagens de programação. Executa um conjunto de atividades num ciclo até que a condição associada às atividades seja avaliada como verdadeira. Você pode especificar um valor de tempo limite para a atividade 'until'. |
| Atividade de espera | Quando se utiliza uma atividade de espera num pipeline, este aguarda o tempo especificado antes de continuar com a execução das atividades subsequentes. |
| Atividade na Web | A atividade da web pode ser usada para invocar um endpoint REST personalizado a partir de um pipeline. |
| Atividade do Webhook | Para utilizar a atividade de webhook, deve chamar um endpoint e passar uma URL de retorno de chamada. A execução do pipeline aguarda que o callback seja invocado antes de prosseguir para a próxima atividade. |
Adicionando atividades a um pipeline com a interface do usuário do Microsoft Fabric
Veja como adicionar e configurar atividades em seu pipeline:
- Crie um novo pipeline em seu espaço de trabalho.
- Vá para a guia Atividades e navegue pelas atividades disponíveis. Role para a direita para ver todas as opções e selecione uma atividade para adicioná-la ao editor de pipeline.
- Ao adicionar uma atividade e selecioná-la na tela, você verá suas Configurações gerais no painel de propriedades abaixo.
- Cada atividade tem outras opções de configuração em outras guias no painel de propriedades.
Configurações gerais
Ao adicionar uma nova atividade a um pipeline e selecioná-la, você verá suas propriedades na parte inferior da tela. Estes incluem Geral, Definições e, por vezes, outros separadores.
Cada atividade inclui campos Nome e Descrição nas configurações gerais. Algumas atividades também têm estas opções:
| Setting | Description |
|---|---|
| Timeout | Quanto tempo uma atividade pode ser executada antes do tempo limite. O padrão é 12 horas e o máximo é sete dias. Use o formato D.HH:MM:SS. |
| Ativar novas tentativas | Quando selecionada, a atividade repete automaticamente em caso de falha. |
| Retry | Quantas vezes tentar novamente se a atividade falhar. O valor padrão é 1. |
| Condições para tentar novamente (versão preliminar) | Configure condições de erro específicas que desencadeem uma nova tentativa. |
| Intervalo de tentativa (seg) | Quantos segundos esperar entre as tentativas de repetição. O padrão é 30 segundos. |
| (Propriedades avançadas) Saída segura | Quando selecionada, a saída da atividade não aparecerá nos registos. |
| (Propriedades avançadas) Entrada segura | Quando selecionada, a entrada de atividade não aparecerá nos logs. |
Note
Por padrão, você pode ter até 120 atividades por pipeline. Isso inclui atividades internas para contêineres.
Tentar novamente uma atividade
Quando uma atividade falha durante a execução do pipeline, pode configurá-la para tentar automaticamente novamente antes de marcar a execução como falhada. Esta funcionalidade é útil para lidar com erros transitórios como timeouts de rede, indisponibilidade temporária de serviços ou problemas intermitentes de ligação.
Saiba mais sobre as definições de repetição e sobre como configurar as repetições aqui.
Desativar uma atividade
Podes desativar uma ou mais atividades de um pipeline para as ignorar durante validações e execuções de pipeline. Esta funcionalidade melhora a eficiência dos programadores do pipeline, permitindo-lhe comentar parte do pipeline sem a eliminar do canvas. Podes reativar as atividades mais tarde.
Desativar atividades
Existem duas formas de desativar uma atividade: desativar uma única atividade no separador Geral, ou desativar várias atividades com o botão direito do rato.
Guarde as alterações para desativar as atividades durante a próxima execução agendada do pipeline.
Desativar uma única atividade
- Selecione a atividade que deseja desativar
- No separador Geral , selecione Desativado para estado de Atividade
- Escolha um estado para Marcar atividade como. Escolha entre Sucesso, Falhado ou Ignorado
Desativar múltiplas atividades
- Pressiona a tecla Ctrl para selecionar várias vezes. Usando o mouse, clique com o botão esquerdo em todas as atividades que você deseja desativar
- Clique com o botão direito do rato para abrir o menu pendente
- Selecione Desativar para desativar todos
- Para ajustar as definições para marcar atividade como, vá ao separador Geral da atividade e faça as alterações apropriadas
Reativar atividades
Para reativar as atividades, escolha Ativado para o Estado de Atividade, e elas revertem aos seus comportamentos anteriores, como esperado.
Comportamentos de atividade inativa
Uma atividade inativa comporta-se de forma diferente num pipeline.
No quadro, a atividade inativa está acinzentada, com o sinal Inativo colocado ao lado do tipo de atividade
Na tela de desenho, é colocado um sinal de estado (Sucedido, Falhado ou Saltado) na caixa, para visualizar a definição de 'Marcar atividade como'
A atividade está excluída do processo de validação do pipeline. Assim, você não precisa fornecer todos os campos obrigatórios para uma atividade inativa.
Durante a execução da depuração e a execução do pipeline, a atividade não será efetivamente executada. Em vez disso, executa um item de linha provisório, com o estado Inativo
A opção de ramificação é controlada pela opção Marcar atividade como. Por outras palavras:
- Se assinalares a atividade como Sucedida, o ramo UponSuccess ou UponCompletion será executado.
- Se assinalares a atividade como Falhada, o ramo UponFailure ou UponCompletion é executado
- Se assinalares a atividade como Skipped, a ramificação UponSkip executa-se
Boas práticas para desativação
A desativação é uma ferramenta poderosa para os desenvolvedores de pipelines. Permite aos programadores "comentar" parte do código, sem apagar permanentemente as atividades. Brilha nos seguintes cenários:
- Ao desenvolver um pipeline, o desenvolvedor pode adicionar atividades inativas como marcador de posição antes de preencher todos os campos obrigatórios. Por exemplo, preciso de uma atividade de cópia do SQL Server para o Data warehouse, mas ainda não configurei todas as conexões. Por isso, uso uma atividade de cópia inativa como espaço reservado para o processo de desenvolvimento iterativo.
- Após a implementação, o desenvolvedor pode comentar certas atividades que estão constantemente a causar problemas, para evitar tentativas dispendiosas. Por exemplo, o meu servidor SQL local está a ter problemas de ligação à rede, e sei com certeza que as minhas atividades de cópia falham. Posso querer desativar a atividade de cópia, para evitar que solicitações de repetição inundem o sistema frágil.
Note
Uma atividade inativa nunca é executada. Isto significa que a atividade não terá um campo de erro, nem os seus campos de saída típicos. Quaisquer referências a campos em falta podem gerar erros mais adiante no processo.
Conteúdo relacionado
- Create your first pipeline (Criar o primeiro pipeline)
- Novas tentativas de atividade