Início / coding / Perguntas / 79318030
Accepted
Patterson
Asked: 2024-12-30 23:59:46 +0800 CST

Como parametrizar uma consulta na atividade de cópia do Azure Data Factory

  • 772

Tenho a seguinte consulta em nossa Atividade de Cópia do ADF

SELECT
  deltaTable.*
FROM Data.deltaTable
LEFT OUTER JOIN Data.targetTable
  ON deltaTable.signature = targetTable.signature
WHERE targetTable.signature IS NULL

Alguém pode me informar como parametrizar a consulta. Quando tento parametrizar a consulta, recebo o erro:

Parameter schema was not found under EX_SourceToRaw_Single_Table

O código a seguir é minha tentativa:

@concat('SELECT * FROM ',pipeline().parameters.schema,'.',pipeline().parameters.DeltaTable)
LEFT OUTER JOIN pipeline().parameters.schema,'.',pipeline().parameters.TargetTable)
  ON pipeline().parameters.DeltaTable).signature = pipeline().parameters.TargetTable).signature
WHERE pipeline().parameters.TargetTable).signature IS NULL

A deltaTable e a TargetTable se parecem com o seguinte:

==========================================================================================================
|    CountryName     |    CountryISO2     |    CountryISO3     |    SalesRegion     |     signature      |
==========================================================================================================
|      Belgium       |     CHA            |     10             |        EMEA        |800e559a27d68f0478b6|
|                    |                    |                    |                    |1c4c9f009e2418e86697|
|                    |                    |                    |                    |1b6e54b549b51b1367ab|
|                    |                    |                    |                    |        450d        |
----------------------------------------------------------------------------------------------------------
|       Wales        |     steveO         |     WAL            |       Welsh        |e8c5149d54986dfe9ac9|
|                    |                    |                    |                    |5a60a76b07603fe17c28|
|                    |                    |                    |                    |2b552ec8255f123b279a|
|                    |                    |                    |                    |        533a        |
----------------------------------------------------------------------------------------------------------
|      Germany       |     DE             |     deletedupd     |        EMEA        |1232b1bd91d14a87ed83|
|                    |                    |                    |                    |0f770d74cd8cabb87153|
|                    |                    |                    |                    |5c4c2b7ff5bcb873fa80|
|                    |                    |                    |                    |        d851        |
----------------------------------------------------------------------------------------------------------
|       Italy        |     IT             |     ITA            |        EMEA        |584cf66de2f4af9eb4db|
|                    |                    |                    |                    |febefea808b1b4e6a357|
|                    |                    |                    |                    |87fcac1061de88cfb798|
|                    |                    |                    |                    |        56df        |
----------------------------------------------------------------------------------------------------------

1 respostas

  1. Best Answer

    Após criar os parâmetros schema, DeltaTable, TargetTableno pipeline ADF, use a expressão abaixo na opção de consulta da atividade de cópia. Aqui, para exemplo, usei a opção de consulta de atividade de pesquisa que funcionará da mesma forma que a opção de consulta de atividade de cópia.

    @concat('SELECT ',pipeline().parameters.DeltaTable,'.* FROM ',pipeline().parameters.schema,'.',pipeline().parameters.DeltaTable,' LEFT OUTER JOIN ',pipeline().parameters.schema,'.',pipeline().parameters.TargetTable,' ON ',pipeline().parameters.DeltaTable,'.signature = ',pipeline().parameters.TargetTable,'.signature WHERE ',pipeline().parameters.TargetTable,'.signature IS NULL')

    Abra o conteúdo dinâmico na consulta e forneça a expressão acima, conforme mostrado abaixo.

    insira a descrição da imagem aqui

    Para verificar a consulta gerada, você pode ir para pipeline run -> activity run -> Input . Aqui, ele mostrará a consulta que foi gerada a partir da expressão acima. Você pode ver que ele gerou a consulta necessária.

    insira a descrição da imagem aqui

    Se ocorrer algum erro, você pode verificar a consulta gerada aqui e modificá-la conforme suas necessidades.

    • 1

relate perguntas