在Azure函数中从Azure服务总线接收JSON（Cosmos DB文档）作为输入

Question

到目前为止，我正在与以下工作：

具有单路输出的f1

#r "Microsoft.Azure.Documents.Client"
#r "Microsoft.ServiceBus"
using Microsoft.ServiceBus.Messaging;
using Microsoft.Azure.Documents;
using System.Collections.Generic;
using System;

public static void Run(IReadOnlyList<Document> inputFeed, TraceWriter log,
    out Document outputSbQueue)
{
  //f1 with a single output to a Queue
}

具有ICollector输出的f1

#r "Microsoft.Azure.Documents.Client"
#r "Microsoft.ServiceBus"
using Microsoft.ServiceBus.Messaging;
using Microsoft.Azure.Documents;
using System.Collections.Generic;
using System;

public static void Run(IReadOnlyList<Document> inputFeed, TraceWriter log,
    ICollector<Document> outputSbQueue)
{
  //f1 with an ICollector output
}    

#r "Microsoft.Azure.Documents.Client"
#r "Newtonsoft.Json"
using Microsoft.Azure.Documents;
using System.Collections.Generic;
using System;
using System.Threading.Tasks;
using Newtonsoft.Json;
public static void Run(Document myQueueItem, TraceWriter log)
{
    //f2 with a working single input -- myQueueItem is an SB trigger
}

#r "Microsoft.Azure.Documents.Client"
#r "Newtonsoft.Json"
using Microsoft.Azure.Documents;
using System.Collections.Generic;
using System;
using System.Threading.Tasks;
using Newtonsoft.Json;

public static void Run(IReadOnlyList<Document> myQueueItem, TraceWriter log)
{
    //f2 with an input of more than one document
}

引发此异常：

2018-05-15T20:48:21.535[错误]执行函数Functions.ServiceBusQueuetRiggerCSharp1时出现异常。Microsoft.Azure.WebJobs.Host：异常绑定参数“My QueueItem”。Microsoft.azure.WebJobs.ServiceBus：将参数绑定到复杂对象（如'ICollector1')使用JSON.NET序列化。1.将参数类型绑定为'string'而不是'icollector1'以获取原始值并避免JSON反序列化，或者2。将队列负载更改为有效的JSON。JSON解析器失败：无法将当前JSON数组（例如[1,2,3])反序列化为类型“Microsoft.Azure.WebJobs.ICollector”1[Microsoft.Azure.Documents.Document]“,因为该类型需要一个JSON对象（例如{”name“：”value“}）才能正确反序列化.要修复此错误，可以将JSON更改为JSON对象（例如{“name”：“value”}），或者将反序列化类型更改为数组或实现集合接口（例如ICollection、IList)的类型，该集合接口可以从JSON数组反序列化。还可以将JsonArrayAttribute添加到类型中，以强制它从JSON数组反序列化。路径'''，行1，位置1。

我是一个处理JSON、序列化和反序列化的完全新手。我只想解析它，从中读取内容，并准备好发送到下游的SQL语句。

Answer 1

目前，服务总线触发器不支持批处理（多项作为输入）。请参见服务总线批处理触发github问题。

如果我正确理解了您的场景，您不一定要在f2函数中接受一个批处理，也不需要“遍历消息的整个队列”。

迭代将由函数处理。您的f2函数将被调用的次数与f1发送到服务总线队列的消息的次数一样多。如果您在获取文档时逐个“清理”这些文档，则最终将清理所有文档。