我想在 V2 中编写一个通用的数据工厂,场景如下。
源--->提取(Salesforce或其他方式(,没有 提取时间戳。---> 我想通过提取将其写入 Blob 时间戳。
我希望它是通用的,所以我不想在任何地方提供列映射。
有没有办法在自定义活动中使用表达式或系统变量在输出数据集中追加列?我喜欢有一个非常简单的解决方案来使实施变得现实。
为此,应更改查询以添加所需的列,并在管道的复制活动中使用 query 属性。 https://learn.microsoft.com/en-us/azure/data-factory/connector-salesforce#copy-activity-properties
我对Salesforce了解不多,但在SQL Server中,你可以执行以下操作:
SELECT *, CURRENT_TIMESTAMP as AddedTimeStamp from [schema].[table]
这将为您提供表上的每个字段,并将添加一个名为 AddTimeStamp 的列,并在结果的每一行中具有CURRENT_TIMESTAMP值。
希望这有帮助!