Azure 数据工厂：如何在转换数据流中实现嵌套 sql 查询
Azure Datafactory: How to implement nested sql query in transformation data flow
[![在此处输入图片描述][1]][1]
我有两个流 customer 和 customercontact。我是天蓝色数据工厂的新手。我只想知道在数据流转换中哪个activity会得到下面sql的查询结果
(SELECT *
来自客户联系
WHERE customerid 在
(SELECT 客户编号
来自客户）
按时间戳降序排序
限制 1)
我可以利用 Exist 转换进行内部查询，但我需要一些帮助来了解如何在对客户联系人 data.So 进行排序后获取第一行，基本上我正在寻找一种方法来添加 limit/Top/Offset 数据流中的子句。
您可以通过不同的转换实现数据流中给定查询的转换。
对于排序，您可以使用排序转换。在这里您可以 select 升序或降序排列。
对于前几条记录，您可以使用排名转换。
对于“IN”子句，您可以使用 Exists 转换。
参考 - https://docs.microsoft.com/en-us/azure/data-factory/data-flow-rank
这是我在 SQL 中的示例数据作为来源
我使用了排名转换。
排名转换后，又添加了一列，即 RankColumn。
现在 select 只有前 1 条记录我使用了筛选行修饰符。我对 select 前 1 条记录使用了 equals(RankColumn,1) 表达式。
现在终于可以使用 Sink activity 和 运行 管道了。
[![在此处输入图片描述][1]][1] 我有两个流 customer 和 customercontact。我是天蓝色数据工厂的新手。我只想知道在数据流转换中哪个activity会得到下面sql的查询结果
(SELECT * 来自客户联系 WHERE customerid 在 (SELECT 客户编号 来自客户） 按时间戳降序排序 限制 1)
我可以利用 Exist 转换进行内部查询，但我需要一些帮助来了解如何在对客户联系人 data.So 进行排序后获取第一行，基本上我正在寻找一种方法来添加 limit/Top/Offset 数据流中的子句。
您可以通过不同的转换实现数据流中给定查询的转换。
对于排序，您可以使用排序转换。在这里您可以 select 升序或降序排列。
对于前几条记录，您可以使用排名转换。
对于“IN”子句，您可以使用 Exists 转换。
参考 - https://docs.microsoft.com/en-us/azure/data-factory/data-flow-rank
这是我在 SQL 中的示例数据作为来源
我使用了排名转换。
排名转换后，又添加了一列，即 RankColumn。
现在 select 只有前 1 条记录我使用了筛选行修饰符。我对 select 前 1 条记录使用了 equals(RankColumn,1) 表达式。
现在终于可以使用 Sink activity 和 运行 管道了。