c# - 使用 VS2017 在 Azure Function 中复制 Blob

Question

我在 Visual Studio 2017 中使用最新的 Azure Function SDK，并且想要将 blob 从一个容器复制到另一个容器。名称保持不变，但将从源 blob 的元数据中检索容器名称。

我一开始只是尝试触发该函数并将元数据包含为:

    [FunctionName("ScanFile")]
    public static void Run([BlobTrigger("tobescanned/{name}", Connection = "AzureWebJobsStorage")]Stream myBlob, IDictionary<string, string> metadata, string name, TraceWriter log)
    {
        log.Info($"C# Blob trigger function Processed blob\n Name:{name} \n Size: {myBlob.Length} Bytes");
        log.Info($"metadata count {metadata.Count}");
    } 

这有效，因此尝试将副本复制为:

    [FunctionName("ScanFile")]
    public static void Run([BlobTrigger("tobescanned/{name}", Connection = "AzureWebJobsStorage")]Stream myBlob, IDictionary<string, string> metadata, string name,
        [Blob("employees/{name}", Connection = "AzureWebJobsStorage")]Stream outputBlob,
        TraceWriter log)
    {
        log.Info($"C# Blob trigger function Processed blob\n Name:{name} \n Size: {myBlob.Length} Bytes");
        log.Info($"metadata count {metadata.Count}");

        myBlob.CopyTo(outputBlob);
    }

但是现在该函数没有被事件调用，因此绑定(bind)出现了问题。我有什么明显做错的事情吗？我发现很难找到使用新 Function SDK 的示例。

下一步(当我让它工作时)是在运行时设置输出容器。我想这可能是这样的:

    [FunctionName("ScanFile")]
    public static void Run([BlobTrigger("tobescanned/{name}", Connection = "AzureWebJobsStorage")]Stream myBlob, IDictionary<string, string> metadata, string name,
        [Blob("{outputContainer}/{name}", Connection = "AzureWebJobsStorage")]Stream outputBlob, string outputContainer,
        TraceWriter log)
    {
        log.Info($"C# Blob trigger function Processed blob\n Name:{name} \n Size: {myBlob.Length} Bytes");
        log.Info($"metadata count {metadata.Count}");

        outputContainer = metadata["Destination"];

        myBlob.CopyTo(outputBlob);
    }

这看起来可行吗(当我让输出工作时)？

谢谢

Answer 1

你的第二个例子在我这边效果很好。这是在我的函数应用程序中生成的函数 JSON。对于 blob 绑定(bind)，方向为“out”。

{
  "bindings": [
    {
      "type": "blobTrigger",
      "path": "tobescanned/{name}",
      "direction": "in",
      "name": "myBlob"
    },
    {
      "type": "blob",
      "path": "employees/{name}",
      "direction": "out",
      "name": "outputBlob"
    }
  ],
  "disabled": false
}

您的第三个示例无法工作，因为触发函数时必须给出输入参数 {outputContainer}。根据您的要求，我建议您使用Azure Storage Blob SDK来完成复制操作。以下代码供您引用。

[FunctionName("ScanFile")]
public static void Run([BlobTrigger("tobescanned/{name}")]CloudBlockBlob myBlob, string name,
    IDictionary<string, string> metadata)
{
    var destinationContainer = myBlob.Container.ServiceClient.GetContainerReference(metadata["Destination"]);
    destinationContainer.CreateIfNotExists();
    CloudBlockBlob outputBlob = destinationContainer.GetBlockBlobReference(name);
    outputBlob.StartCopy(myBlob);
}