要在ADF触发器中使用Blob,需要进行以下步骤:
创建一个Blob存储帐户。
创建一个Blob容器以存储Blob文件。
在ADF中创建一个数据集,其中来源类型为Blob存储,并指定Blob容器的名称。
创建一个触发器,将触发器的类型设置为Blob触发器,指定你需要监听的Blob容器路径。
下面是一个示例代码,可以使用Blob触发器触发时自动运行:
{
"name": "blobtrigger",
"properties": {
"annotations": [],
"runtimeState": "Started",
"pipelines": [
{
"pipelineReference": {
"referenceName": "mypy-py-file-pipe",
"type": "PipelineReference"
},
"parameters": {
"inputblobname": "{trigger().outputs.blobname}"
},
"waitOnCompletion": true,
"waitTimeInSeconds": 0
}
],
"type": "BlobTrigger",
"typeProperties": {
"blobPathBeginsWith": "inputcontainer/{year}/{month}/{day}/{hour}/{minute}",
"connectionString": ""
}
},
"type": "Microsoft.DataFactory/factories/triggers"
}
在这个代码中,当触发器检测到新的Blob文件时,它会调用"mypy-py-file-pipe"的管道,该管道需要一个输入Blob参数,可以使用JSON的形式来设置参数键和值。