事件网格触发函数在函数成功运行后保持触发？

Question

我有一个由事件网格事件触发的Azure函数。仅当blob上载到存储帐户时，才会创建事件网格事件。

虽然由于某些原因，该函数仍然会被同一事件触发，即使它已成功处理，但它现在已部署并运行良好？

例子：

今天我查看了日志，该函数已继续执行！

错误:“Blob不存在”

代码片段：

def main(event: func.EventGridEvent):

        result = json.dumps({
            'id' : event.id,
            'data' : event.get_json(),
            'topic' : event.topic,
            'subject' : event.subject,
            'event_type' : event.event_type
        })

        logging.info('EventGrid trigger processing an event: %s', result)

        credential = DefaultAzureCredential()

        download_start_time = datetime.datetime.now()
        logging.info(f'######## Starting downloading blob from storage at ' + str(download_start_time) + ' ########')

        # =============================
        # Download blob from storage container:
        # =============================

        blob_client = BlobClient.from_blob_url(event.get_json()["url"], credential)
        blob_data = blob_client.download_blob().readall()
        blob_byte_stream = io.BytesIO(blob_data)

编辑1:这仍在发生，这次有点不同。

• 现在，EventGrid在成功传递消息和函数运行后继续触发

我如何调试它？

Answer 1

我终于弄清楚了问题是什么...使用 Azure 存储资源管理器测试 blob 上传时，使用BlobClient.from_blob_url方法工作正常。但是，使用 Azure 数据工厂时，将使用不同的 API，并且 EventGrid 消息中的 data.url 属性不是实际的 blob url（包含 dfs 而不是 blob）。

奇怪的是，在我向支持团队提出这个问题后不久，一个新的< code>blobUrl属性被添加到EventGrid data对象中。

在我的代码中，我简单地将“url”改为“blobUrl”，方法成功了。（我还改进了Python代码的错误处理，以适应将来的错误。）

记录的事件网格消息(截至2020年12月10日):

• No blobUrl 属性

[{
  "topic": "/subscriptions/{subscription-id}/resourceGroups/Storage/providers/Microsoft.Storage/storageAccounts/my-storage-account",
  "subject": "/blobServices/default/containers/my-file-system/blobs/new-file.txt",
  "eventType": "Microsoft.Storage.BlobCreated",
  "eventTime": "2017-06-26T18:41:00.9584103Z",
  "id": "831e1650-001e-001b-66ab-eeb76e069631",
  "data": {
    "api": "CreateFile",
    "clientRequestId": "6d79dbfb-0e37-4fc4-981f-442c9ca65760",
    "requestId": "831e1650-001e-001b-66ab-eeb76e000000",
    "eTag": "\"0x8D4BCC2E4835CD0\"",
    "contentType": "text/plain",
    "contentLength": 0,
    "contentOffset": 0,
    "blobType": "BlockBlob",
    "url": "https://my-storage-account.dfs.core.windows.net/my-file-system/new-file.txt",
    "sequencer": "00000000000004420000000000028963",  
    "storageDiagnostics": {
    "batchId": "b68529f3-68cd-4744-baa4-3c0498ec19f0"
    }
  },
  "dataVersion": "2",
  "metadataVersion": "1"
}]

实际事件网格消息现在通过：

• 注意bobUrl已添加到架构

{
    "id": "long-string",
    "data": {
        "api": "CreateFile",
        "requestId": "long-string",
        "eTag": "0x8D89B4FF7150079",
        "contentType": "application/octet-stream",
        "contentLength": 0,
        "contentOffset": 0,
        "blobType": "BlockBlob",
        "blobProperties": [{
            "acl": [{
                "access": "u::rw,u:long-string:rwx,u:long-string:rwx,g::rx,g:long-string:rx,m::rw,o::",
                "permission": "0660",
                "owner": "long-string",
                "group": "$superuser"
            }]
        }],
        "blobUrl": "https://myfunction.blob.core.windows.net/container/20201208/730420201208080239.csv",
        "url": "https://myfunction.dfs.core.windows.net/container/20201208/730420201208080239.csv",
        "sequencer": "0000000000000000000000000000692c00000000000e1a99",
        "identity": "long-string",
        "storageDiagnostics": {
            "batchId": "long-string"
        }
    },
    "topic": "/subscriptions/long-string/resourceGroups/myResourceGroup/providers/Microsoft.Storage/storageAccounts/storageAccount",
    "subject": "/blobServices/default/containers/container/blobs/20201208/730420201208080239.csv",
    "event_type": "Microsoft.Storage.BlobCreated"
}

这里还有一个警告…请注意上面消息中的内容长度

• CreateFile API 不是指示已创建 Blob 的实际消息。
• FlushWithClose API 是

关于这一点，文档中有一个注释。所以我还必须设置一个EventGrid高级过滤器，它只在生成< code>FlushWithClose事件时触发(！idspninfopath _ NV)。)