Счетчик агрегатов фабрики данных Azure ()

У меня есть запрос с несколькими объединениями, и есть поле, которое создается из счетчика, например:

select
t1.clientID,
t1.clientName,
t2.invoiceNo
(select count (*) from invoices where clientID = t1.clientID) AS clientswithSale
from customers t1
JOIN invoices t2 on t2.clientID = t1.clientID

как я могу создать этот столбец, используя агрегированное преобразование внутри потока данных с несколькими источниками?

могу ли я связать источник с функцией count ()?

Спасибо


azure-data-factory-2
person Luis Jacobo    schedule 12.08.2020    source источник

Ответы (2)


arrow_upward
0
arrow_downward

Этот оператор SQL в потоке данных ADF приравнивается к:

Источник (счета-фактуры), Источник (клиенты), Внутреннее объединение, Агрегирование (количество)

person Mark Kromer MSFT    schedule 14.08.2020

arrow_upward
0
arrow_downward

Недавно я провел еще один тест, и общий процесс выглядит следующим образом: Источник (счета-фактуры), Источник (клиенты), Присоединение, Агрегирование (подсчет).

  1. Я создаю два источника и позже соединю их ключом SalesOrderID. source1 Таблица заказчиков по аналогии и source2 таблица счетов-фактур по аналогии. введите описание изображения здесь

  2. Затем я объединяю источник2, Группировать по SalesOrderID и Агрегаты с выражением count(1) следующим образом: введите описание изображения здесь введите описание изображения здесь

  3. В конце я соединяю два источника с ключом SalesOrderID, и это хорошо работает. введите описание изображения здесь

person Joseph Xu    schedule 13.08.2020
comment
Привет, это мой способ обойти эту проблему, но каждый источник потока данных представляет собой инкрементную нагрузку от SQL onpremise к datalake, и это поле является частью всего потока, который погружается в новый набор данных в Azure SLQ. Вот почему мне нужно сделать это count (), используя загруженные источники. какие-нибудь советы, как обойти это? - person Luis Jacobo; 13.08.2020