You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I am trying to find an adequate solution to implementing following process in BullMQ.
* acquire information A
* process information from A to B
- publish B to message broker
- store B in DBMS 1
* process information from B to C
- publish C to message broker
- store C in DBMS 2
I read about FlowProducer and initally thought they might be a good fit. But from what I saw they are good at having multiple children jobs aggregated in one parent job which processes their output. So in my case If I map all the steps in a flow I would need multiple parent jobs, which is not possible.
My next idea is to create a Flow with steps [acquire, process, process] and have them add jobs to separate queues for DBMS 1, DBMS 2 and message broker. But in that case, do I still need the FlowProducer?
What are your thoughts?
The text was updated successfully, but these errors were encountered:
I am trying to find an adequate solution to implementing following process in BullMQ.
I read about FlowProducer and initally thought they might be a good fit. But from what I saw they are good at having multiple children jobs aggregated in one parent job which processes their output. So in my case If I map all the steps in a flow I would need multiple parent jobs, which is not possible.
My next idea is to create a Flow with steps [acquire, process, process] and have them add jobs to separate queues for DBMS 1, DBMS 2 and message broker. But in that case, do I still need the FlowProducer?
What are your thoughts?
The text was updated successfully, but these errors were encountered: