文章/答案/技术大牛

发布

社区首页 >问答首页 >Azure数据工厂活动复制:使用@pipeline().TriggerTime评估接收表中的列

问Azure数据工厂活动复制:使用@pipeline().TriggerTime评估接收表中的列
EN

Stack Overflow用户

提问于 2018-09-28 18:27:41

回答 2查看 1.8K关注 0票数 2

使用数据工厂V2，我试图实现从一个Azure SQL数据库到另一个数据库的数据流复制。

我已经将源表的所有列映射到了接收表，但是在接收表中，我有一个空列，我想在其中输入管道运行时间。

有没有人知道如何在接收表中填充此列而不将其显示在源表中？

下面是我的复制管道的代码

{
"name": "FLD_Item_base",
"properties": {
    "activities": [
        {
            "name": "Copy_Team",
            "description": "copytable",
            "type": "Copy",
            "policy": {
                "timeout": "7.00:00:00",
                "retry": 0,
                "retryIntervalInSeconds": 30,
                "secureOutput": false,
                "secureInput": false
            },
            "typeProperties": {
                "source": {
                    "type": "SqlSource"
                },
                "sink": {
                    "type": "SqlSink",
                    "writeBatchSize": 10000,
                    "preCopyScript": "TRUNCATE TABLE Team_new"
                },
                "enableStaging": false,
                "dataIntegrationUnits": 0,
                "translator": {
                    "type": "TabularTranslator",
                    "columnMappings": {
                        "Code": "Code",
                        "Name": "Name"
                    }
                }
            },
            "inputs": [
                {
                    "referenceName": "Team",
                    "type": "DatasetReference"
                }
            ],
            "outputs": [
                {
                    "referenceName": "Team_new",
                    "type": "DatasetReference"
                  }
              ]
          }
      ]
  }
}

在我的接收表中，我已经有了列data_load，我想在其中插入管道执行日期，但是我当前没有映射它。

azure-data-factory-2

azure

azure-sql-database

azure-data-factory

回答 2

Stack Overflow用户

发布于 2018-10-01 14:32:55

根据您的情况，作为解决办法，请在SQL Server接收器中配置SQL Server存储过程。

请按照此doc中的步骤进行操作

第1步:配置Sink数据集：

第2步:在复制活动中配置接收器部分，如下所示：

步骤3:在数据库中，定义与sqlWriterTableType同名的表类型。请注意，表类型的模式应该与输入数据返回的模式相同。

    CREATE TYPE [dbo].[testType] AS TABLE(
    [ID] [varchar](256) NOT NULL,
    [EXECUTE_TIME] [datetime] NOT NULL
)
GO

步骤4:在数据库中，定义与SqlWriterStoredProcedureName同名的存储过程。它处理来自指定来源的输入数据，并合并到输出表中。请注意，存储过程的参数名称应与dataset中定义的"tableName“相同。

Create PROCEDURE convertCsv @ctest [dbo].[testType] READONLY
AS
BEGIN
  MERGE [dbo].[adf] AS target
  USING @ctest AS source
  ON (1=1)
  WHEN NOT MATCHED THEN
      INSERT (id,executeTime)
      VALUES (source.ID,GETDATE());
END

票数 2

Stack Overflow用户

发布于 2018-09-28 21:38:51

您可以考虑在接收端使用存储过程，通过指定SqlSink的"“将源数据应用到接收表中。将管道运行时作为参数传递给存储过程，并插入到接收器表中。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/52553365

复制

相似问题

问Azure数据工厂活动复制:使用@pipeline().TriggerTime评估接收表中的列
EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Azure数据工厂活动复制:使用@pipeline().TriggerTime评估接收表中的列EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Azure数据工厂活动复制:使用@pipeline().TriggerTime评估接收表中的列
EN