You are here:
OM Plus Data Event Streaming
OM Plus can automatically send a list of events to a Kinesis data stream, where you use your own tools to consume the data (for example, load it into your data warehouse for analysis).
The data remains in the stream for 24 hours after it's published. After 24 hours, the data is removed from the stream, so you should make sure that your tools pick it up within that time.
The data stream shows changes to catalog records such as product specs, plan definition, order items, and so on. Those changes are published in near real-time.
To set up Data Event Streaming, contact the Cloud Engineering team. You'll just need to provide the relevant AWS account number and role.
The data in the stream differs depending on your setup, but here are some examples of the kind of data that you might expect:
Sample Data for Order
{
"Account Id": "0012x000004xuvq",
"Modified": "2020-09-20 22:21:39.978+00",
"Orchestration Plan": 77405618597879921,
"Parent": 4412964684870431366,
"_action": "insert",
"First Version Order": 77405618597879914,
"Created": "2020-09-20 22:21:39.978+00",
"Name": "00001237",
"Salesforce Id": "8012x000000mvqr",
"Encryption Key Version": null,
"Container": null,
"State": "In Progress",
"Object Type": "Order",
"id": 77405618597879914,
"Jeopardy Safety Interval Unit": "Seconds",
"Package": null
}Sample Data for Sales Order Item
{
"Action": "Add",
"Modified": "2020-09-20 22:21:39.982+00",
"Parent": 77405618597879914,
"Downstream Are Ready For Activation": "true",
"Asset Reference Id": "3ff25056-1d2f-c99f-c445-ca7c9c6855e3",
"_action": "insert",
"Bundle Order Item": 77405618597879915,
"Created": "2020-09-20 22:21:39.982+00",
"Name": "39667Source Product_1",
"Salesforce Id": "8022x000000x3pz",
"Container": null,
"Logging Context": "8012x000000mvqr",
"Is Changes Allowed": "true",
"Condition Fields": "{\"field\":\"action__c\",\"value\":\"Add\"}",
"id": 77405618597879915,
"Jeopardy Safety Interval Unit": "Seconds",
"Order": 77405618597879914,
"Jeopardy Safety Interval": "0",
"Product Specification": 77405618597788698,
"Sales Top Order Item": 77405618597879915,
"Encryption Key Version": null,
"Children Are Ready For Activation": "true",
"Billing Account Id": "0012x000004xuvq",
"State": "In Progress",
"Characteristic Values": "{\"39667TEXT_ATTRIBUTE1\":\"10\"}",
"Object Type": "Order Item",
"Package": null,
"Trackable": "false",
"Line Number": "0002",
"Service Account Id": "0012x000004xuvq"
}Sample Data for Decomposed Order Item
{
"Action": "NoChange",
"Order Item Number": "T00101386",
"Modified": "2020-09-20 22:21:42.824+00",
"Parent": 77405618597879934,
"Downstream Are Ready For Activation": "true",
"Asset Reference Id": "b5dbd30a-77c4-40c7-8106-2831e1785dfa",
"_action": "insert",
"Bundle Order Item": 77405618597879933,
"Created": "2020-09-20 22:21:42.824+00",
"Name": "39667Directory Listing Mobile",
"Salesforce Id": null,
"Container": null,
"Is Downstream Order Item": "true",
"Logging Context": "8012x000000mvqr",
"Is Changes Allowed": "true",
"id": 77405618597879935,
"Associated OrchItems Are In Final State": "true",
"Order": 77405618597879941,
"Product Specification": 77405618597788677,
"Asset/Inventory Item": 77405618597808143,
"Encryption Key Version": null,
"Children Are Ready For Activation": "true",
"Billing Account Id": "0012x000004xuvq",
"State": "In Progress",
"Characteristic Values": "{}",
"Object Type": "Order Item",
"Package": null,
"Trackable": "false",
"Line Number": "0001.0001.0001",
"Source Order Items": [
77405618597879915,
77405618597879917
],
"Service Account Id": "0012x000004xuvq"
}