你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。
适用于：
Azure Data Factory Azure Synapse Analytics
提示
Microsoft Fabric 中的 Data Factory 是下一代 Azure Data Factory，具有更加简化的架构、内置人工智能和新功能。 如果不熟悉数据集成，请从Fabric数据工厂开始。 现有 ADF 工作负载可以升级到 Fabric，以跨数据科学、实时分析和报告访问新功能。
数据工厂管道中的 HDInsight Pig 活动会在自己的或按需 HDInsight 群集上执行 Pig 查询。 本文基于数据转换活动一文，它概述了数据转换和受支持的转换活动。
若要了解详细信息，请阅读 Azure Data Factory 或 Synapse Analytics 简介，并在阅读本文之前执行 Tutorial：转换数据。
使用用户界面将 HDInsight Pig 活动添加到管道中
要将 HDInsight Pig 活动用于管道，请完成以下步骤：
在管道“活动”窗格中搜索 Pig，然后将 Pig 活动拖到管道画布上。
在画布上选择新的 Pig 活动（如果尚未选择）。
选择“HDI 群集”选项卡以选择或创建新的链接到 HDInsight 群集的服务，该群集将用于执行 MapReduce 活动。
选择 Script 选项卡，以选择或创建新的脚本关联服务，并将其关联到将托管脚本的 Azure Storage 位置。 指定要在其中执行的类名，以及存储位置内的文件路径。 还可以配置高级详细信息，包括调试配置以及要传递给脚本的实参和形参。
语法
{
"name": "Pig Activity",
"description": "description",
"type": "HDInsightPig",
"linkedServiceName": {
"referenceName": "MyHDInsightLinkedService",
"type": "LinkedServiceReference"
},
"typeProperties": {
"scriptLinkedService": {
"referenceName": "MyAzureStorageLinkedService",
"type": "LinkedServiceReference"
},
"scriptPath": "MyAzureStorage\\PigScripts\\MyPigScript.pig",
"getDebugInfo": "Failure",
"arguments": [
"SampleHadoopJobArgument1"
],
"defines": {
"param1": "param1Value"
}
}
}
语法详细信息
| 属性 | 描述 | 必需 |
|---|---|---|
| 名称 | 活动名称 | 是 |
| 描述 | 描述活动用途的文本 | 否 |
| 类型 | 对于 Hive 活动，活动类型为 HDinsightPig | 是 |
| linkedServiceName | 引用作为连接服务注册的 HDInsight 群集。 若要了解此链接服务，请参阅计算链接服务一文。 | 是 |
| scriptLinkedService | 对 Azure 存储链接服务的引用，该服务用于存储要执行的 Pig 脚本。 此处仅支持 Azure Blob Storage 和 ADLS Gen2 链接服务。 如果未指定此链接服务，将使用 HDInsight 链接服务中定义的Azure Storage链接服务。 | 否 |
| 脚本路径 | 提供 scriptLinkedService 引用的Azure Storage中存储的脚本文件的路径。 文件名称需区分大小写。 | 否 |
| getDebugInfo | 指定何时将日志文件复制到由 scriptLinkedService 指定的 HDInsight 群集（或）使用的Azure Storage。 允许的值：“无”、“始终”或“失败”。 默认值：无。 | 否 |
| 参数 | 指定 Hadoop 作业的参数数组。 参数以命令行参数的形式传递到每个任务。 | 否 |
| 定义 | 在 Pig 脚本中指定参数作为键/值对，以供引用。 | 否 |
相关内容
参阅以下文章了解如何以其他方式转换数据：