run bullQ job like AWS stepfunction
npm install bull-stepfunctionbull-stepfunction is a Node.js module that provides the ability to control queues and jobs using StepFunction JSON format. It leverages the power of Bull queues to manage asynchronous tasks and offers an intuitive way to structure job execution using StepFunction-like syntax.
bull-stepfunction using npm:
sh
npm install bull-stepfunction
`
Usage
`js
const {StepFunction} =require("bull-stepfunction");
const Queue =require("bull");
const path =require("path");
const testjobQ = require("./testJob")
const testjobQ1 = require("./testJob1")
const testjobQ2 = require("./testJob2")
const testQ = new Queue("fetch", "redis://127.0.0.1:6381");
const testQ1 = new Queue("fetch1", "redis://127.0.0.1:6381");
const testQ2 = new Queue("fetch2", "redis://127.0.0.1:6381");
testQ.process(20, testjobQ)
testQ1.process(20, testjobQ1)
testQ2.process(20, testjobQ2)
let sf = new StepFunction(path.join(__dirname, './simple.asl.json'),{testjob:testQ,testjob1:testQ1,testjob2:testQ2},{loging:false,redis:"redis://127.0.0.1:6381"})
sf.init({d:[{ss:"ss"},{dd:"dd"},{ff:"ff"}]})
sf.on('complete',(result)=>{
console.log("step function process has been finished , final result is :",result)
})
`
first we import package with
`js
const {StepFunction} =require("bull-stepfunction");
`
after that we define it with new StepFunction
`js
let sf = new StepFunction(path.join(__dirname, './simple.asl.json'),{testjob:testQ,testjob1:testQ1,testjob2:testQ2},{loging:false,redis:"redis://127.0.0.1:6381"})
`
this will get three arguments
- path of stepfunction json
- the object map job from asl.json to job queue you defined in code
- redis and loging configuration
after that we init the class with data we want to pass to it
`js
sf.init({d:[{ss:"ss"},{dd:"dd"},{ff:"ff"}]})
`
and we could run code in complete event
`js
sf.on('complete',({workflowId,data})=>{
console.log("step function process has been finished ")
})
``