DB API Reference¶
- async process_message(db, payload)[source]¶
Processes a tracing message storing it to the db.
- Parameters
db – The database object to use.
payload (dict) – A dict representing the message to store.
Can be either a tracing run creation in the form of:
- msg = {
“msg_type”: “create_trace_run”, “app_name”: app_name, “uuid”: identifier, “column_names”: [“v1”, ‘v2’]
}
or for the insertion of a tracing row:
- msg = {
“msg_type”: “row”, “uuid”: identifier, “row_data”: [12.2, 123.1]
}
raises: InvalidMessage