Orchestration that receives multiple events
- Vorherrschende Sprache
- C#
- Sterne
- 1.7k
- Forks
- 335
- Ø Merge
- 2 T. 23 Std.
- Gemergte PRs (30 T.)
- 6
Beschreibung
Can anyone share an example of an orchestration that receives multiple events?
I'm trying to create an orchestration that will wait for an event, process that event, and then wait for the next event, in an "endless" loop. Something along the lines of (NON WORKING CODE BELOW):
``` csharp
public class SignalOrchestration : TaskOrchestration
{
TaskCompletionSource resumeHandle;
public override async Task RunTask(OrchestrationContext context, string input)
{
do
{
string job = await WaitForSignal();
await context.ScheduleTask("ExecuteJob", string.Empty, job);
}
while (true);
return string.Empty;
}
async Task WaitForSignal()
{
this.resumeHandle = new TaskCompletionSource();
string data = await this.resumeHandle.Task;
return data;
}
public override void OnEvent(OrchestrationContext context, string name, string input)
{
this.resumeHandle?.SetResult(input);
}
}
```
and I should be able to send events to this orchestration.
The idea is to have something similar to an Actor - the orchestration representing a resource, and I'd like to handle the jobs on the resource as they arrive...
Beitragsleitfaden
Für dieses Repository ist kein Beitragsleitfaden indexiert
Rechercherichtung
Das Issue erwähnt TaskOrchestration.RunTask und OnEvent, nennt aber keine Repository-Dateien oder Tests. Beginne damit nachzuverfolgen, wie Orchestrierungsereignisse zugestellt werden und ob das Framework wiederholtes dauerhaftes Warten auf Ereignisse unterstützt; vergleiche dieses Verhalten anschließend mit der bereitgestellten nicht funktionierenden Schleife. Als Ergebnis sollte ein dokumentiertes funktionierendes Beispiel oder ein ausdrücklich abgegrenzter Implementierungspfad zur Verarbeitung aufeinanderfolgender Ereignisse vorliegen.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Bewertung
- Tech-Stack
- csharp
- Bereich
- backend, distributed-systems
- Issue-Typ
- Feature
- Schwierigkeit
- 5/5
- Geschätzter Aufwand
- Über eine Woche
- Aktivitätsstatus
- Veraltet
- Klarheit
- Muss geklärt werden
- Anfängerfreundlichkeit
- 25/100