ExampleTemplate
Morning operations digest from three systems
Weekdays at 7 am, reads 311 requests, SentraQueue lobby visits and database work orders, puts them in one shape, combines and sorts them, emails a count of open items by source, and archives the whole list as JSON on SFTP.
This flow
13 steps
StartsOn a schedule
SystemsSentra 311, SentraQueue, PostgreSQL / PostGIS, SFTP server
Branches1
Stored recordsNone: pass-through
§ The flow
The whole flow, as it appears on the canvas.
Scroll sideways on small screens. Colors show the kind of step: start, read, change, decide, write.
§ Step by step
What each step does.
- 01 · Start · On a schedule
Weekdays at 7 am
- Weekdays at 7:00 am (workspace time zone)
Then: 311 requests; Lobby visits; Work orders
- 02 · Read · Get records · Sentra 311
311 requests
- Reads Service requests from Sentra 311
- At most 500 records per run
Then: As one shape
- 03 · Read · Get records · SentraQueue
Lobby visits
- Reads Visits (tickets) from SentraQueue
- At most 500 records per run
Then: As one shape
- 04 · Database · Read database · PostgreSQL / PostGIS
Work orders
- Reads from PostgreSQL / PostGIS table
work_orders - Row ID column:
ref(used for replay and lineage)
Then: As one shape
- Reads from PostgreSQL / PostGIS table
- 05 · Change · Map fields
As one shape
- Shapes each record into 5 fields:
source,ref,status,area,updated
Then: Combine
- Shapes each record into 5 fields:
- 06 · Change · Map fields
As one shape
- Shapes each record into 5 fields:
source,ref,status,area,updated
Then: Combine
- Shapes each record into 5 fields:
- 07 · Change · Map fields
As one shape
- Shapes each record into 5 fields:
source,ref,status,area,updated
Then: Combine
- Shapes each record into 5 fields:
- 08 · Decide · Combine
Combine
- Combines the records from every incoming wire into one list
Then: Newest first
- 09 · Change · Sort
Newest first
- Sorts by
updated, newest / largest first
Then: Still open?; Archive as JSON
- Sorts by
- 10 · Decide · If / else
Still open?
- Yes when
statusis one ofopen, in_progress, waiting, called
Then: Yes → Count by source
- Yes when
- 11 · Files · Write file · SFTP server
Archive as JSON
- Writes JSON file
operations-digest-{{ $today }}.jsontooutbox - One file with every record
- Writes JSON file
- 12 · Change · Summarize
Count by source
- Counts records by
source
Then: Email the digest
- Counts records by
- 13 · Act · Send email
Email the digest
- Emails
[email protected]: “Good morning: open items across 311, the lobby and work orders” - One summary email
- Emails
§ Systems
Connectors used
Swap any of them for another system with the same kind of data.
Run this flow on your systems.
We'll set up a workspace with your systems in a sandbox and build your first flow with you.