Azure Functions - Blob 流输出绑定
Azure Functions - Blob Stream output binding
我创建了一个带有 blob 存储触发器的 Azure 函数 - 我想处理一个文件,然后将文件转储到另一个 blob 存储容器。
在最简单的情况下,我想它看起来像这样:
public static void Run(Stream blob, string name, out Stream outputBlob, TraceWriter log)
{
outputBlob = blob;
}
这些是我的绑定:
{
"bindings": [
{
"name": "blob",
"type": "blobTrigger",
"direction": "in",
"path": "input/{name}",
"connection": "wlimportstaging_STORAGE"
},
{
"name": "outputBlob",
"type": "blob",
"direction": "out",
"path": "original/{name}",
"connection": "wlimportstaging_STORAGE"
}
],
"disabled": false
}
我从文档中了解到,如果您 return 一个 POCO,它会将其序列化为 JSON。
https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-storage-blob#output-usage
这似乎表明您可以输出到流 - 我似乎只是得到:
Microsoft.Azure.WebJobs.Host: Can't bind Blob to type 'System.IO.Stream&
请协助!
这很好用。如果有更好的方法,我会非常感兴趣。
public static async Task Run(Stream blob, string name, Stream outBlob, TraceWriter log)
{
using (MemoryStream ms = new MemoryStream())
{
blob.CopyTo(ms);
var byteArray = ms.ToArray();
await outBlob.WriteAsync(byteArray, 0, byteArray.Length);
}
}
你也一样
public static async Task Run(Stream myBlob, string name, Stream outputBlob, TraceWriter log)
{
await myBlob.CopyToAsync(outputBlob);
}
我创建了一个带有 blob 存储触发器的 Azure 函数 - 我想处理一个文件,然后将文件转储到另一个 blob 存储容器。
在最简单的情况下,我想它看起来像这样:
public static void Run(Stream blob, string name, out Stream outputBlob, TraceWriter log)
{
outputBlob = blob;
}
这些是我的绑定:
{
"bindings": [
{
"name": "blob",
"type": "blobTrigger",
"direction": "in",
"path": "input/{name}",
"connection": "wlimportstaging_STORAGE"
},
{
"name": "outputBlob",
"type": "blob",
"direction": "out",
"path": "original/{name}",
"connection": "wlimportstaging_STORAGE"
}
],
"disabled": false
}
我从文档中了解到,如果您 return 一个 POCO,它会将其序列化为 JSON。
https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-storage-blob#output-usage
这似乎表明您可以输出到流 - 我似乎只是得到:
Microsoft.Azure.WebJobs.Host: Can't bind Blob to type 'System.IO.Stream&
请协助!
这很好用。如果有更好的方法,我会非常感兴趣。
public static async Task Run(Stream blob, string name, Stream outBlob, TraceWriter log)
{
using (MemoryStream ms = new MemoryStream())
{
blob.CopyTo(ms);
var byteArray = ms.ToArray();
await outBlob.WriteAsync(byteArray, 0, byteArray.Length);
}
}
你也一样
public static async Task Run(Stream myBlob, string name, Stream outputBlob, TraceWriter log)
{
await myBlob.CopyToAsync(outputBlob);
}