Kann ich mehrere Elemente aus einer einzigen Ausführung einer Azure-Funktion in eine Warteschlange stellen?

Question

Ich habe eine Node.js timerTrigger Azure-Funktion, die eine Sammlung verarbeitet und die Verarbeitungsergebnisse für die weitere Verarbeitung in eine Warteschlange stellt (durch eine Node.js queueTrigger-Funktion).

Der Code ist so etwas wie die folgenden:

module.exports = function (context, myTimer) { 
    collection.forEach(function (item) { 
     var items = []; 

     // do some work and fill 'items' 

     var toBeQueued = { items: items }; 

     context.bindings.myQueue = toBeQueued; 
    }); 

    context.done(); 
}; 

Dieser Code wird nur die letzte toBeQueued Warteschlange und nicht jeder, den ich in die Warteschlange bin versucht.

Gibt es eine Möglichkeit, mehr als einen Artikel in die Warteschlange zu stellen?

aktualisieren

klar sein, ich spreche über eine toBeQueued in jeder Iteration von forEach Warteschlangen, nicht nur ein Array Warteschlangen. Ja, es gibt ein Problem mit Azure-Funktionen, aufgrund dessen ich ein Array nicht in die Warteschlange stellen kann, aber ich habe einen Workaround dafür; d.h. { items: items }.

Answer 1

Noch nicht, aber wir werden das innerhalb der Woche angehen, bleib dran :) Du wirst in der Lage sein, ein Array an die Bindung zu übergeben, wie du oben versuchen willst.

Wir haben ein Problem, das dies in unserem öffentlichen Repo here verfolgt. Danke für die Berichterstattung.

Answer 2

Mathewcs Antwort ist die richtige mit Knoten.

Für C# können Sie heute ICollector<T> als den Typ Ihrer Ausgabewarteschlangenparameter angeben.

Unten ist ein Beispiel von zwei Ausgabewarteschlangen, von denen ich eine über eine for-Schleife hinzufüge.

public static void Run(Item inbound, DateTimeOffset InsertionTime, ICollector<Item> outbound, ICollector<LogItem> telemetry, TraceWriter log) 
{ 
    log.Verbose($"C# Queue trigger function processed: {inbound}"); 

    telemetry.Add(new LogItem(inbound, InsertionTime)); 

    if(inbound.current_generation < inbound.max_generation) 
    { 
     for(int i = 0; i < inbound.multiplier; i++) { 
      outbound.Add(Item.nextGen(inbound)); 
     } 
    } 
}