azure-data-factory - CosmosToBlobCopyActivity 的 ADFv1 到 ADFv2 迁移

Question

我正在将 ADFv1 下的一些管道迁移到 ADFv2。

我发现一个管道的活动类型为CosmosToBlobCopyActivity。这不是 CosmosDB，而是 Cosmos 结构流数据。

ADFv2 中的等价物是什么

"activities": [
        {
            "type": "CosmosToBlobCopyActivity",
            "typeProperties": {
                "EmailRecipients": "[e-mail]"
            },
            "inputs": [
                {
                    "name": "DS_INPUT"
                }
            ],
            "outputs": [
                {
                    "name": "DS_OUTPUT"
                }
            ],
            "policy": {
                "timeout": "04:00:00",
                "concurrency": 1,
                "executionPriorityOrder": "NewestFirst",
                "retry": 3,
                "longRetry": 10,
                "longRetryInterval": "01:10:00"
            },
            "scheduler": {
                "frequency": "Day",
                "interval": 1
            },
            "name": "CosmosToBlobCopyActivity",
            "description": "Pipeline Activity: CosmosToBlobCopyActivity",
            "linkedServiceName": "DEMOLS"
        }
    ]

标签： azure-data-factoryazure-data-factory-2cosmos

Answer 1

Azure DataFactory 没有名为“CosmosToBlobCopyActivity”的活动类型。这是 ADF v1 中的自定义活动。因此，您需要在 ADF v2 中创建自定义活动。

您可以查看以下文档：

这是在 v1 中创建自定义活动的方法：

https://docs.microsoft.com/en-us/azure/data-factory/v1/data-factory-use-custom-activities#create-a-pipeline-with-custom-activity

这是在 v2 中创建自定义活动的方法：

https://docs.microsoft.com/en-us/azure/data-factory/transform-data-using-dotnet-custom-activity