Example of workflow taking external json input into queue

mperestrelo · June 18, 2023, 9:26pm

I had a use case where I need to send json records in an array to be created as corteza records.

I was exploring ways to use the corteza queue to return quicker to the client application and then have a second workflow to consume the records placed on the queue.

github.com

mperestrelo/corteza-examples/blob/main/README.md

# corteza-examples
Examples for corteza use cases


Here are some use case examples for Corteza

1. Invoking an external workflow to write to a queue (with consumptions by a second workflow)

* The write to queue is invoked by an external http request, like so:

Step 1. Obtain a login token (see login png) and stored JWT token (I am using postman, so save it to context - i.e. in tests I place this:

var jsonData = JSON.parse(responseBody);
postman.setGlobalVariable("access_token", jsonData.access_token);

Step 2. Post to the workflow which writes to the queue

POST http://localhost:808/automation/workflows/339721397272051813/exec

Headers:

This file has been truncated. show original

What is happens here is:

Use postman to post to the workflow using escaped json string
First workload reads array and writes each element to the queue
Consumer workflow reads each element and creates a record

Note that the tricky bit was escaping the JSON should it would be created correctly in the consumer.