Atividade da função Azure no Azure Data Factory

APLICA-SE A: Azure Data Factory Azure Synapse Analytics

A atividade Azure Function permite que você execute Azure Functions em um pipeline do Azure Data Factory ou do Synapse. Para executar uma função Azure, você deve criar uma conexão de serviço vinculada. Em seguida, você pode usar o serviço vinculado com uma atividade que especifica a função Azure que você planeja executar.

Criar uma atividade de Azure Function com UI

Para usar uma atividade de função Azure em um pipeline, conclua as seguintes etapas:

1. Expanda a seção Função do Azure do painel Atividades do pipeline e arraste uma atividade de função do Azure para a tela do pipeline.

2. Selecione a nova atividade da Função Azure no painel, se ainda não estiver selecionada, e na guia Configurações, edite os seus detalhes.

   

3. Se você ainda não tiver um serviço vinculado Azure Function definido, selecione Novo para criar um novo. No novo painel de serviço vinculado do Azure Function, escolha a url do aplicativo de funções Azure existente e forneça uma Chave de Função.

   

4. Depois de selecionar o serviço vinculado Azure Function, forneça o nome da função e outros detalhes para concluir a configuração.

serviço vinculado do Azure Functions

O tipo de retorno da função Azure deve ser um JObject válido. (Tenha em mente que JArraynão é um JObject.) Qualquer tipo de retorno diferente de JObject falha e gera o erro de usuário Conteúdo de Resposta não é um JObject válido.

A Chave de Função fornece acesso seguro ao nome da função com cada uma delas tendo chaves exclusivas ou chave mestra separadas em um aplicativo de funções. A identidade gerenciada fornece acesso seguro a todo o aplicativo de funções. O usuário precisa fornecer a chave para acessar o nome da função. Para saber mais, confira a documentação da função para obter mais detalhes sobre a Chave de acesso de função

/* A resourceId propriedade é necessária quando você usa a autenticação de identidade gerenciada atribuída pelo sistema.

Autenticação de identidade gerenciada atribuída pelo sistema

Você pode usar a autenticação SAMI (identidade gerenciada) atribuída pelo sistema de duas maneiras:

• Defina a ID do recurso como https://management.azure.com. O Data Factory se conecta ao Aplicativo de Funções usando sua identidade gerenciada atribuída pelo sistema e executa o aplicativo de funções com autenticação anônima.

• Para ambientes seguros em que você não deseja usar a autenticação anônima, configure um SPN (Nome da Entidade de Serviço) como a ID do Recurso. O SPN deve ser configurado corretamente no Aplicativo de Funções:

  1. Crie um novo registro de aplicativo como uma identidade principal de serviço.

  2. Em seu aplicativo de funções, vá para a seção Autenticação em Configurações e crie um provedor de identidade.

  3. Adicione o ADF ID do Aplicativo na seção Solicitações Permitidas de Aplicativos Cliente Específicos e a ID do Objeto na seção Permitir Solicitações de Identificadores Específicos. A ID do aplicativo e a ID do objeto podem ser encontradas seguindo estas etapas:

     1. Abra o portal Azure
     2. Ir para aplicativos empresariais
     3. Busque pelo seu Azure Data Factory/Nome da identidade gerenciada.
     4. Copie as IDs do objeto e do aplicativo encontradas na tabela.

     

Atividade da função Azure

Consulte o esquema da carga de solicitação na seção Esquema de carga de solicitação.

Roteamento e consultas

A atividade de função Azure dá suporte a roteamento. Por exemplo, se a função Azure tiver o ponto de extremidade https://functionAPP.azurewebsites.net/api/<functionName>/<value>?code=<secret>, o functionName a ser usado na Atividade de Função Azure será <functionName>/<value>. Você pode parametrizar essa função para fornecer as desejadas functionName no tempo de execução.

A Atividade de Função Azure também dá suporte a queries. Uma consulta deve ser incluída como parte de functionName. Por exemplo, quando o nome da função é HttpTriggerCSharp e a consulta que você deseja incluir é name=hello, então você pode construir o functionName na Atividade de Função Azure como HttpTriggerCSharp?name=hello. Essa função pode ser parametrizada para que o valor possa ser determinado no tempo de execução.

Funções de tempo limite e execução longa

O Azure Functions atinge o tempo limite após 230 segundos, independentemente da configuração functionTimeout que você tenha definido. Para obter mais informações, consulte este artigo. Para contornar esse comportamento, siga um padrão assíncrono ou use Durable Functions. A vantagem de Durable Functions é que elas oferecem seu próprio mecanismo de controle de estado, portanto, você não precisa implementar o seu.

Saiba mais sobre Durable Functions neste artigo. Você pode configurar uma atividade de função Azure para chamar a Função Durável, que retornará uma resposta com um URI diferente, como esta exemplo. Como statusQueryGetUri o retorna o status HTTP 202 enquanto a função está em execução, você pode sondar o status da função usando uma Atividade da Web. Configure uma Atividade da Web com o campo url definido como @activity('<AzureFunctionActivityName>').output.statusQueryGetUri. Quando a função durável for concluída, a saída da função será a saída da atividade da Web.

Amostra

Você pode encontrar um exemplo que usa uma função Azure para extrair o conteúdo de um arquivo tar here.

Conteúdo relacionado

Saiba mais sobre as atividades com suporte Pipelines e atividades.