Azure 数据工厂存储事件触发器未启动管道

Question

我创建了一个存储事件触发器来启动 Azure 数据工厂中的管道。我知道它配置得很好，因为我可以在通过 UI 手动上传 Blob 后成功触发它。但是使用 TypeScript 和下面的脚本，可以成功创建 blob，但事件触发器不起作用。我读到我们需要使用 Flush 方法，但不确定如何在 TypeScript 中完成。

这是我正在使用的代码：

import { BlobServiceClient } from "@azure/storage-blob"

async function handleWriteToBlob(blobData, insurance) {
  const jsonData = sendJson(blobData);
  const containerName = "raw-layer";
  const fileName = blobData['timestamp'];
  const blobName = `/folder_name/${insurance}/${insurance}-insurance_form-${fileName.toISOString()}.json`;

  const blobServiceClient = new BlobServiceClient(`https://${accountName}.blob.core.windows.net?${sasToken}`);
  const containerClient = blobServiceClient.getContainerClient(containerName)
  const blockBlobClient = containerClient.getBlockBlobClient(blobName);

  const options = {
    blobHTTPHeaders: {
      blobContentType: 'application/json'
    },
    bufferThreshold: 4 * 1024 * 1024, // 4MB
    maxBuffers: 20 // 80MB
  };

  const result = await blockBlobClient.upload(
    jsonData,
    jsonData.length,
    options
  );

  if (result.errorCode) {
    throw Error(result.errorCode);
  }

  console.log(`Uploaded BlockBlob ${blobName} successfully as: ${jsonData}`);
}

function sendJson(blobData) {
  console.log(`${JSON.stringify(blobData)}`);
  return JSON.stringify(blobData);
}