Agendar trabalhos do U-SQL usando SSIS (SQL Server Integration Services)

Neste documento, você aprende como orquestrar e criar trabalhos do U-SQL usando SSIS (SQL Server Integration Service).

Importante

O Azure Data Lake Analytics desativado em 29 de fevereiro de 2024. Saiba mais nesse comunicado.

Para análise de dados, sua organização pode usar o Azure Synapse Analytics ou o Microsoft Fabric.

Pré-requisitos

O Feature Pack do Azure para Serviços de Integração fornece a tarefa do Azure Data Lake Analytics e o Gerenciador de Conexões do Azure Data Lake Analytics que ajuda a conectar o serviço do Azure Data Lake Analytics. Para usar essa tarefa, certifique-se de instalar:

• Baixar e instalar o SSDT (SQL Server Data Tools) para o Visual Studio
• Instalar o Feature Pack do Azure para SSIS (Integration Services)

Tarefa do Azure Data Lake Analytics

A tarefa do Azure Data Lake Analytics permite que os usuários enviem trabalhos do U-SQL para a conta do Azure Data Lake Analytics.

Saiba como configurar a tarefa do Azure Data Lake Analytics.

É possível obter o script do U-SQL de diferentes locais usando as funções e tarefas internas do SSIS; os cenários abaixo mostram como você pode configurar os scripts do U-SQL para diferentes casos de usuários.

Cenário 1 - Use o script em linha chamado tvfs e procedimentos armazenados

No Editor de Tarefas do Azure Data Lake Analytics, configure SourceType como DirectInput e coloque as instruções do U-SQL em USQLStatement.

Para facilitar a manutenção e o gerenciamento de código, coloque apenas scripts curtos de U-SQL como scripts embutidos, por exemplo, você pode chamar funções de valor de tabela existentes e procedimentos armazenados nos bancos de dados do U-SQL.

Artigo relacionado: Como passar parâmetros para procedimentos armazenados

Cenário 2 - Usar arquivos do U-SQL no Azure Data Lake Store

Também é possível usar arquivos do U-SQL no Azure Data Lake Store usando a Tarefa do Sistema de Arquivos do Azure Data Lake Store no Feature Pack do Azure. Essa abordagem permite usar os scripts armazenados na nuvem.

Siga as etapas abaixo para configurar a conexão entre a Tarefa do Sistema de Arquivos do Azure Data Lake Store e a Tarefa do Azure Data Lake Analytics.

Definir fluxo de controle de tarefa

No modo de exibição de design do pacote SSIS, adicione uma Tarefa do Sistema de Arquivos do Azure Data Lake Store, um Contêiner do Loop Foreach e uma Tarefa do Azure Data Lake Analytics no contêiner do Loop Foreach. A Tarefa do Sistema de Arquivos do Azure Data Lake Store ajuda a baixar arquivos do U-SQL da conta do ADLS para uma pasta temporária. O Contêiner do Loop Foreach e a Tarefa do Azure Data Lake Analytics ajudam a enviar cada arquivo do U-SQL na pasta temporária para a conta do Azure Data Lake Analytics como uma tarefa do U-SQL.

Configurar Tarefa do Sistema de Arquivos do Azure Data Lake Store

1. Defina a Operação para CopyFromADLS.
2. Configure AzureDataLakeConnection, saiba mais sobre o Gerenciador de conexões do Azure Data Lake Store.
3. Defina AzureDataLakeDirectory. Aponte para a pasta que armazena os scripts do U-SQL. Use o caminho relativo que é relativo à pasta raiz da conta do Azure Data Lake Store.
4. Defina o Destino para uma pasta que armazene em cache os scripts do U-SQL baixados. Este caminho de pasta será usado no Contêiner do Loop Foreach para envio de trabalhos do U-SQL.

Saiba mais sobre a Tarefa do Sistema de Arquivos do Azure Data Lake Store.

Configurar o Contêiner do Loop Foreach

1. Na página Coleção, defina Enumerador para Enumerador de Arquivo Foreach.

2. Defina Pasta no grupo Configuração do enumerador para a pasta temporária que inclui os scripts do U-SQL baixados.

3. Defina Arquivos em Configuração do enumerador para *.usql, de modo que o contêiner de loop capture apenas os arquivos que terminam com .usql.

   

4. Na página Mapeamentos de Variáveis adicione uma variável definida pelo usuário para obter o nome do arquivo para cada arquivo do U-SQL. Defina o Índice para 0 para obter o nome do arquivo. Neste exemplo, defina uma variável chamada User::FileName. Essa variável será usada para obter dinamicamente a conexão do arquivo de script do U-SQL e definir o nome da tarefa do U-SQL na tarefa do Azure Data Lake Analytics.

   

Configurar tarefa do Azure Data Lake Analytics

1. Defina SourceType para FileConnection.

2. Defina FileConnection como a conexão de arquivo que aponta para os objetos de arquivo retornados do Contêiner do Loop Foreach.

   Para criar essa conexão de arquivo:

   1. Escolha <Nova conexão...> na configuração FileConnection.

   2. Defina Tipo de uso para Arquivo existente e defina o Arquivo para o caminho de arquivo de qualquer arquivo existente.

      

   3. Na exibição Gerenciadores de Conexões , clique com o botão direito do mouse na conexão de arquivo criada e escolha Propriedades.

   4. Na janela Propriedades, expanda Expressões e defina ConnectionString para a variável definida no Contêiner do Loop Foreach, por exemplo, @[User::FileName].

      

3. Defina AzureDataLakeAnalyticsConnection na conta do Azure Data Lake Analytics para a qual deseja enviar tarefas. Saiba mais sobre o Gerenciador de Conexões do Azure Data Lake Analytics.

4. Defina outras configurações de trabalho. Saiba mais.

5. Use Expressões para definir dinamicamente o nome do trabalho do U-SQL:

   1. Na página Expressões, adicione um novo par chave-valor de expressão para JobName.

   2. Configure o valor de JobName para a variável definida no Contêiner do Loop Foreach, por exemplo, @[User::FileName].

      

Cenário 3 - Usar arquivos do U-SQL no Armazenamento de Blobs do Azure

É possível usar arquivos do U-SQL no Armazenamento de Blobs do Azure, usando a Tarefa de Download de Blob do Azure no Feature Pack do Azure. Essa abordagem permite usar os scripts na nuvem.

As etapas são semelhantes ao Cenário 2: usar arquivos do U-SQL no Azure Data Lake Storage. Altere a Tarefa do Sistema de Arquivos do Azure Data Lake Store para Tarefa de Download de Blob do Azure. Saiba mais sobre a Tarefa de Download de Blob do Azure.

O fluxo de controle é assim:

Cenário 4 - Usar arquivos do U-SQL no computador local

Além de usar arquivos do U-SQL armazenados na nuvem, você também poderá usar arquivos no computador local ou arquivos implantados com os pacotes SSIS.

1. Clique com o botão direito do mouse em Gerenciadores de Conexões no projeto SSIS e escolha Novo Gerenciador de Conexões.

2. Selecione Tipo de arquivo e selecione Adicionar....

3. Defina Tipo de uso para Arquivo existente e defina o Arquivo para o arquivo no computador local.

   

4. Adicione a tarefa do Azure Data Lake Analytics e:

   1. Defina SourceType para FileConnection.
   2. Defina FileConnection como a Conexão de Arquivo criada.

5. Conclua outras configurações para Tarefa do Azure Data Lake Analytics.

Cenário 5 - Usar instrução do U-SQL na variável do SSIS

Em alguns casos, talvez seja necessário gerar dinamicamente as instruções U-SQL. É possível usar a Variável do SSIS com a Expressão do SSIS e outras tarefas do SSIS, como Tarefa Script, para ajudá-lo a gerar a instrução do U-SQL dinamicamente.

1. Abra a janela de ferramentas Variáveis no menu de nível superior SSIS > Variáveis.

2. Adicione uma variável do SSIS e defina o valor diretamente ou use a Expressão para gerar o valor.

3. Adicione a Tarefa do Azure Data Lake Analytics e:

   1. Defina SourceType para Variável.
   2. Defina SourceVariable como a Variável SSIS criada agora.

4. Conclua outras configurações para Tarefa do Azure Data Lake Analytics.

Cenário 6 - Passar parâmetros para script do U-SQL

Em alguns casos, talvez você queira definir dinamicamente o valor da variável U-SQL no script U-SQL. O recurso mapeamento de parâmetros no Azure Data Lake Analytics Task ajuda nesse cenário. Geralmente, há dois casos típicos de usuários:

• Defina as variáveis de caminho do arquivo de entrada e saída dinamicamente com base na data e hora atuais.
• Defina o parâmetro para procedimentos armazenados.

Saiba mais sobre como definir parâmetros para o script do U-SQL.

Próximas etapas

• Executar pacotes SSIS no Azure
• Feature Pack do Azure para o Integration Services (SSIS)
• Agendar trabalhos do U-SQL usando o Azure Data Factory