I have a scenario in mind where I want to run a workflow for every message in an event log (Azure Event Hubs over AMQP 1.0 in my scenario). Are there any examples that deal with such integration, with the goal to guarantee “effectively once” processing?
Temporal is fully consistent and does guarantee workflow uniqueness by its id. So you’ll have to assign workflow ids based on deduping logic you need. Also make sure to set WorkflowOptions.WorkflowIDReusePolicy to WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE to not allow to start duplicated workflows after previous one completed.