Ingesting Metrics with the Push Metrics REST API
You can use LogicMonitor Push Metrics REST API to programmatically ingest metrics for multiple instances associated with a single resource and DataSource.
The Push Metrics REST API requires LMv1 API Token Authentication.
Request Information
The metric ingestion endpoint is used to push metrics to one or more instances associated with a DataSource and resource. Only one resource and DataSource is supported per request. If this is the first time metrics are being pushed to a resource, this request will result in a new DataSource and optionally a new resource (depending on parameters).
| Method | Post |
| Base URL | https://{ACCOUNTNAME}.logicmonitor.com/rest |
| Path | metric/ingest |
| Header | Authorization: LMv1 token |
| Parameter | (Optional)https://companyxyz.logicmonitor.com/rest/metric/ingest?create=trueIf create=true, a new resource will be created if there is no match for the provided resource IDs. The default value is “false”. |
| Content-Type | application/json |
| Specification | { “resourceName”: “<Resource name>”, //Optional when create flag is not specified “resourceDescription”: “<Resource description>”, “resourceIds” : { //Mandatory “key1” : “value1”, “key2” : “value2”,… //Multi-values accepted }, “resourceProperties”: { “key1” : “value1”, “key2” : “value2”,… //Multi-values accepted } “dataSourceId”: “<DataSource ID>” //Either dataSourceId or dataSource mandatory “dataSource”: “<DataSource Name>” //Either dataSourceId or dataSource mandatory “dataSourceDisplayName”: “<Display Name for the DataSource>” “dataSourceGroup”: “<DataSource Group name>” “instances”:[ { “instanceName”: “<Instance Name>”, //Mandatory “instanceDisplayName”: “<Instance display Name>” “instanceProperties”: { “key1” : “value1”, “key2” : “value2”,… }, “dataPoints”: [ { “dataPointName”: “<Datapoint Name>”, //Mandatory “dataPointDescription”: “<Datapoint Description>”, “dataPointType”: “<Datapoint Metric Type>”, “dataPointDataType”: “<Datapoint Data Type>”, |
Use the following mandatory and optional fields in your request.
| Field Name | Description | Type | Required? | Validations |
| resourceName | Resource unique name. Only considered when creating a new resource. | String | Required only if the create parameter is set to TRUE (create=true). FALSE is the default. | – 255-character limit – Must be unique – Should not start or end with spaces, tabs, etc – Should not contain line breaks – Characters from A-Z, a-z, and 0-9 allowed as well as colons, hyphens, underscores and full stops – No whitespace allowed |
| resourceDescription | Resource description. Only considered when creating a new resource. | String | Optional. Defaults to “”. | – 65535-character limit |
| resourceIds | An array of existing resource properties that will be used to identify the resource. See Managing Resources that Ingest Push Metrics for information on the types of properties that can be used. If no resource is matched and the create parameter is set to TRUE, a new resource is created with these specified resource IDs set on it. If the system.displayname and/or system.hostname property is included as resource IDs, they will be used as host name and display name respectively in the resulting resource. | JSON object | Required | – Takes input as key-value pairs in the form of property name and assigned value (example: “system.displayname” : “mcentos”) – Keys and values are strings – All characters except , ; / * [ ] ? ‘ ” ` ## and newline are allowed -Spaces allowed except at start or end – Keys and values should not contain backslashes (\)Null key and value are not allowed – Keys have 255-character limits; values have 24000-character limits – Case insensitive |
| resourceProperties | New properties for resource. Updates to existing resource properties are not considered. Depending on the property name, we will convert these properties into system, auto, or custom properties. | JSON object | Optional. Defaults to “”. | – Takes input as key-value pairs in the form of property name and assigned value (Example: “version” : “5.0”) – System properties are not allowed (example: system.xxx)Auto properties are not allowed (example: auto.xxx) – Keys and values are stringsAll characters except , ; / * [ ] ? ‘ ” ` ## and newline are allowed – Spaces allowed except at start or end – Keys and values should not contain backslashes (\) – Null key and value are not allowed – Keys have 255-character limits; values have 24000-character limitsCase insensitive |
| dataSourceId | DataSource unique ID. Used only to match an existing DataSource. If no existing DataSource matches the provided ID, an error results. If this field is used in combination with the dataSource field, both the ID and name provided must match a single DataSource or an error results. | Integer | Either dataSourceId or dataSource is mandatory. | – 9-digit limit – Only positive whole numbers allowed |
| dataSource | DataSource unique name. Used to match an existing DataSource. If no existing DataSource matches the name provided here, a new DataSource is created with this name. If this field is used in combination with the dataSourceId field, both the ID and name provided must match a single DataSource or an error is returned. | String | Either dataSourceId or dataSource is mandatory. | – 64-character limit – Must be unique – All characters except , ; / * [ ] ? ‘ ” ` ## and newline are allowed – Spaces allowed except at start or end – Hyphen allowed only at the end; hyphen must be used with at least one other character |
| dataSourceDisplayName | DataSource display name. Only considered when creating a new DataSource. | String | Optional. Defaults to dataSource. | – 64-character limit – All characters except , ; / * [ ] ? ‘ ” ` ## and newline are allowed – Spaces are allowed except at start or end – Keys and values should not contain backslashes (\) – Hyphen allowed only at the end; hyphen must be used with at least one other character |
| dataSourceGroup | DataSource group name. Only considered when DataSource does not already belong to a group. Used to organize the DataSource within a DataSource group. If no existing DataSource group matches, a new group is created with this name and the DataSource is organized under the new group. | String | Optional. Defaults to “PushModules”. | – 128-character limit – Only supports characters from A-Z, a-z, 0-9, colon, hyphen, underscore, and whitespace – Values should not be null, empty, or having trailing spaces |
| instances | An array of DataSource instances. | JSON object | Required | |
| instanceName | Instance name. If no existing instance matches, a new instance is created with this name. | String | Required | – 255-character limit – All characters except , ; / * [ ] ? ‘ ” ` ## and newline are allowed – Spaces allowed except at start or end – Should not contain backslashes (\). – Only supports characters from A-Z, a-z, 0-9, colon, hyphen, underscore, and full stop – No whitespace allowed |
| instanceDisplayName | Instance display name. Only considered when creating a new instance. | String | Optional. Defaults to {instanceName}. | – 255-character limit – All characters except , ; / * [ ] ? ‘ ” ` ## and newline are allowed – Spaces allowed except at start or end – Should not contain backslashes (\).*<?,;`\\n characters not allowed |
| instanceProperties | New properties for instance. Updates to existing instance properties are not considered. Depending on the property name, we will convert these properties into system, auto, or custom properties. | JSON object | Optional. Defaults to “”. | – Takes input as key-value pairs in the form of property name and assigned value – System properties are not allowed (example: system.xxx) – Auto properties are not allowed (example: auto.xxx) – Keys and values are stringsAll characters except , ; / * [ ] ? ‘ ” ` ## and newline are allowed – Spaces allowed except at start or end – Keys and values should not contain backslashes (\) – Keys have 255-character limits; values have 24000-character limits – Case insensitive – Keys and values should not be null, empty, or having trailing spaces |
| dataPointName | Datapoint name. If no existing datapoint matches for specified DataSource, a new datapoint is created with this name. | String | Required | – 128-character limit Characters from A-Z, a-z, and 0-9 only allowed – Should not contain reserved keywords such as COS, SIN, etc. |
| dataPointDescription | Datapoint description. Only considered when creating a new datapoint. | String | Optional. Defaults to {dataPointName}. | 1024-character limit |
| dataPointType | Metric type as a number in string format. Only considered when creating a new datapoint. | String | Optional. Defaults to “gauge”. | – Only values of “counter”, “derive”, or “guage” accepted – Case insensitive |
| dataPointAggregationType | The default aggregation interval is for one minute. The aggregation is calculated based on the aggregation type (sum/average/none/min/max) of the data occurring within a minute. For more information, see About the Push Metrics REST API. | String | Optional. Defaults to “none”. | – Only values of “min”, “max”, “none”, “avg”, “sum”, or “percentile” accepted – Case insensitive |
| percentileValue | If “percentile” is specified for dataPointAggregationType, this field is required for specifying the percent value to use. | Integer | Required when dataPointAggregationType is percentile | – Any whole number percentage between 0-100. Example: 99|95|90|70|50 (no default) |
| values | An array of datapoint values | JSON object | Required | –Takes input as key-value pairs in the form of epoch time and datapoint value. Example: “1584902069” : “10″ -Only long type values accepted in keys –Digits accepted in values or scientific notation Example:4.93e-2, 1.89502e202 |
Example
The following Python 3 example monitors CPU utilization.
#!/usr/bin/env python3
import time, os, sys
import hmac, hashlib, base64
import requests
import json
import psutil
#--------------------------------------
# Constants - Do not change
#--------------------------------------
resource_path = '/metric/ingest'
headers = {
'Content-Type': 'application/json'
}
#---------------------------------------
# Change Values below as per your setup
#---------------------------------------
def get_params():
# Account info
# Your account name
Company = "ABC"
# User account Access Id for which it must have permissions to manage resources and manage LogicModules
AccessId = "6wDEvh73taGMPP43SSmF"
AccessKey = 'Q)cfY2w8u[G97jkz5^P8{HT)g-uq[6+E8LL%Mb{^'
url = "https://"+Company+".logicmonitor.com/rest"+ resource_path
return url, AccessId, AccessKey
#--------------------------------------------
# Function to send metric data to LM Platform
#--------------------------------------------
def send_metrics(timestamp, body):
url, AccessId, AccessKey = get_params()
req_var = "POST" + str(timestamp) + body +resource_path;
signature = base64.b64encode(bytes(hmac.new(
bytes(AccessKey, 'latin-1'),
bytes(req_var, 'latin-1'),
digestmod=hashlib.sha256
).hexdigest(), 'latin-1')).decode('latin-1')
auth = "LMv1 "+AccessId+ ":"+ signature+":"+str(timestamp)
headers['Authorization'] = auth
try:
response = requests.post(url, verify=True, headers=headers, data=body, params={"create":'true'})
if response.status_code != 202:
print('Failed to send metric. Error:', response.status_code, response.text)
else:
print("SUCCESS :",response.text)
except Exception as e:
print("Unable to connect. Error: ", e)
#--------------------------------------------
# Prepare REST payload
#--------------------------------------------
def prepare_request_body(metric, timestamp, data_value):
return json.dumps({
"resourceName": metric["device_name"],
"resourceIds": {
"system.displayname": metric["device_name"],
"system.ips": metric["device_ip"]
},
"dataSource": metric["data_source"],
"dataSourceDisplayName": metric["data_source"],
"instances": [
{
"instanceName": metric["instance"],
"instanceDisplayName": metric["instance"],
"instanceProperties": {
"version": "1",
},
"dataPoints": [
{
"dataPointName": metric["data_point"],
"dataPointType": "GAUGE",
"dataPointAggregationType": "sum",
"values": {
str(timestamp//1000): data_value
}
},
]
},
]
}).replace("'", '"')
#------------------
#==== MAIN =======
#------------------
if __name__ == "__main__":
my_metric = {}
my_metric["device_name"] = os.uname()[1]
my_metric["device_ip"] = "192.168.1.1"
my_metric["data_source"] = "CPU"
my_metric["instance"] = "cpu-1"
my_metric["data_point"] = "cpu_utilization"
while True:
timestamp = int(time.time()*1000)
data_value = psutil.cpu_percent()
body = prepare_request_body(my_metric, timestamp, data_value)
send_metrics(timestamp, body)
time.sleep(10)