stegus64
02/09/2026, 9:54 PM{
"success": true,
"statusCode": 0,
"errorMessage": "string",
"additionalMessage": "string",
"returnedRows": 0,
"totalRowCount": 0,
"emails": [
{
"reference_id": 0,
"mail_id": "string",
"received": "2026-02-09T10:33:52.058Z",
"sent": "2026-02-09T10:33:52.058Z",
"read": true,
"priority": "Normal",
"subject": "string",
"attachmentCount": 0,
"attributeCount": 0,
"attributeList": [
{
"reference_id": 0,
"mail_attribute_id": "string",
"mail_id": "string",
"key": "string",
"value": "string",
"keep": true,
"comment": "string"
}
]
}
]
}
In this case I want to create one email table, and one email_attributes table.flarco
02/09/2026, 11:04 PMyaml
queues:
- email_attribute_records
endpoints:
email:
description: "Retrieve emails and push attribute records to queue"
request:
url: "{state.base_url}/emails"
parameters:
limit: "{state.limit}"
response:
records:
jmespath: "emails[]"
primary_key: ["reference_id"]
processors:
# For each email record, construct an object per attribute
# and push it into the queue with the parent mail_id attached
- expression: >
jmespath(record, "attributeList[].{
reference_id: reference_id,
mail_attribute_id: mail_attribute_id,
mail_id: mail_id,
key: key,
value: value,
keep: keep,
comment: comment
}")
output: "queue.email_attribute_records"
- expression: object_delete(record, "attributeList")
output: record
# no extra API call when iteration into "response.records"
email_attribute:
description: "Emit email attributes from queue"
iterate:
over: "queue.email_attribute_records"
into: "response.records"
response:
records:
primary_key: ["reference_id"]stegus64
02/10/2026, 12:19 AM