Poll Internet Router Usage - SNMP + INFLUX

[scurvy-dog]

Hi folks. This is a new work flow that I put together to monitor my Internet router cellular interface. I wanted to retrieve the current amount of inbound bytes so I can monitor my monthly cellular usage in Grafana. So I have several components used in this flow.

• SNMP GET node. (Pulls the OID for inbound octets on router)
• Influx query. (Pulls last record so I can get the billing cycle counter)
• Influx write. (When everything is compiled writes data to db using JSON format)
• Switch Nodes (Checking if current day is start of new billing cycle)
• Use of flow variables

Last you may be able to completely skip the HEX->DEX function. There is some weird behaviour in the SNMP node. If I pulled a 32 bit counter it would return the value correctly in the payload. I needed though to pull the counter as a 64 bit value and when I pulled that the SNMP node returned the raw HEX data not a integer value. So this function is just to covert the raw hex data into a base-10 integer.

[scurvy-dog]

[scurvy-dog]

[
{
"id": "1d4107a3.0d96e8",
"type": "tab",
"label": "Cell Data Usage",
"disabled": false,
"info": ""
},
{
"id": "61e5c8f2.3d9088",
"type": "snmp",
"z": "1d4107a3.0d96e8",
"host": "192.168.1.1",
"community": “public”,
"version": "2c",
"oids": "1.3.6.1.2.1.31.1.1.1.6.1",
"timeout": 5,
"name": "SNMP GET CELL 0",
"x": 350,
"y": 200,
"wires": [
[
"6ddb2ada.1dc724"
]
]
},
{
"id": "83a6589b.cfbb48",
"type": "inject",
"z": "1d4107a3.0d96e8",
"name": "Start 12:01 AM",
"props": [
{
"p": "payload"
}
],
"repeat": "14400",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "",
"payloadType": "date",
"x": 120,
"y": 80,
"wires": [
[
"2c643754.9d11e8",
"da733a8f.595638"
]
]
},
{
"id": "6ddb2ada.1dc724",
"type": "function",
"z": "1d4107a3.0d96e8",
"name": "Convert from HEX to DEC",
"func": "var a;\nvar b = "";\nvar c = "";\n\n// Loop through msg paylod array\nfor (i=0; i < msg.payload[0].value.length; i++) {\n a = msg.payload[0].value[i];\n b = a.toString(16);\n // pad hex value to 2 digits\n if (b.length < 2) { \n b = "0" + b;\n }\n // Concate each raw hex value together\n c = c + b;\n}\n// Convert HEX to DECIMAL\nd = parseInt(c,16);\n\n// Merge and convert from hex to decimal\nflow.set("SNMP_Bytes_OUT",d);\n\nmsg.payload = d;\n\nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 610,
"y": 200,
"wires": [
[
"12f3449e.84422b"
]
]
},
{
"id": "427f860b.42a208",
"type": "influxdb out",
"z": "1d4107a3.0d96e8",
"influxdb": "a8c3eca7.425fb",
"name": "Influx InternetDb",
"measurement": "cellularData",
"precision": "",
"retentionPolicy": "",
"database": "database",
"precisionV18FluxV20": "ms",
"retentionPolicyV18Flux": "",
"org": "organisation",
"bucket": "bucket",
"x": 820,
"y": 380,
"wires": []
},
{
"id": "da733a8f.595638",
"type": "influxdb in",
"z": "1d4107a3.0d96e8",
"influxdb": "a8c3eca7.425fb",
"name": "Query Last Record",
"query": "select last(billing_cycle), base_line from cellularData",
"rawOutput": false,
"precision": "",
"retentionPolicy": "",
"org": "organisation",
"x": 350,
"y": 120,
"wires": [
[
"f2f8b8e6.e953c8"
]
]
},
{
"id": "2caf40a0.b0e6b",
"type": "function",
"z": "1d4107a3.0d96e8",
"name": "Write Point - Reset Billing Cycle",
"func": "var n;\nn = flow.get("Cycle_Nmb");\n\n// New billing cycle then increment cycle number\n++n;\n\nmsg.payload = {\n "billing_cycle": n,\n "base_line": flow.get("SNMP_Bytes_OUT"),\n "bytes_in": flow.get("SNMP_Bytes_OUT")\n}\nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 550,
"y": 340,
"wires": [
[
"427f860b.42a208"
]
]
},
{
"id": "2c643754.9d11e8",
"type": "function",
"z": "1d4107a3.0d96e8",
"name": "Check Day of Month",
"func": "var date = new Date().getDate();\nmsg.payload.billing= {};\n\n// t-mobile billing cycle starts on 10th\nif (date == 10) {\n msg.payload.billing = true;\n flow.set("Start_Billing_Cycle",true);\n} else {\n msg.payload.billing = false;\n flow.set("Start_Billing_Cycle",false);\n}\n\nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 360,
"y": 40,
"wires": [
[]
]
},
{
"id": "12f3449e.84422b",
"type": "switch",
"z": "1d4107a3.0d96e8",
"name": "Check Billing Cycle",
"property": "Start_Billing_Cycle",
"propertyType": "flow",
"rules": [
{
"t": "true"
},
{
"t": "false"
}
],
"checkall": "true",
"repair": false,
"outputs": 2,
"x": 210,
"y": 380,
"wires": [
[
"2caf40a0.b0e6b"
],
[
"ba00af80.3f63a"
]
]
},
{
"id": "ba00af80.3f63a",
"type": "function",
"z": "1d4107a3.0d96e8",
"name": "Write Point - In Billing Cycle",
"func": "msg.payload = {\n "billing_cycle": flow.get("Cycle_Nmb"),\n "base_line": flow.get("Base_Line"),\n "bytes_in": flow.get("SNMP_Bytes_OUT")\n}\nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 540,
"y": 420,
"wires": [
[
"427f860b.42a208"
]
]
},
{
"id": "f2f8b8e6.e953c8",
"type": "change",
"z": "1d4107a3.0d96e8",
"name": "Set Billing Cycle / Base Line",
"rules": [
{
"t": "set",
"p": "Cycle_Nmb",
"pt": "flow",
"to": "payload[0].last",
"tot": "msg"
},
{
"t": "set",
"p": "Base_Line",
"pt": "flow",
"to": "payload[0].base_line",
"tot": "msg"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 620,
"y": 120,
"wires": [
[
"b3933f76.d0928",
"61e5c8f2.3d9088"
]
]
},
{
"id": "b3933f76.d0928",
"type": "switch",
"z": "1d4107a3.0d96e8",
"name": "IF Empty",
"property": "Cycle_Nmb",
"propertyType": "flow",
"rules": [
{
"t": "null"
}
],
"checkall": "true",
"repair": false,
"outputs": 1,
"x": 860,
"y": 120,
"wires": [
[
"6dd89911.6447f8"
]
]
},
{
"id": "6dd89911.6447f8",
"type": "change",
"z": "1d4107a3.0d96e8",
"name": "Set Cycle",
"rules": [
{
"t": "set",
"p": "Cycle_Nmb",
"pt": "flow",
"to": "1",
"tot": "num"
}
],
"action": "",
"property": "",
"from": "",
"to": "",
"reg": false,
"x": 1040,
"y": 120,
"wires": [
[]
]
},
{
"id": "a8c3eca7.425fb",
"type": "influxdb",
"hostname": "127.0.0.1",
"port": "8086",
"protocol": "http",
"database": "Internet",
"name": "InfluxDb",
"usetls": false,
"tls": "",
"influxdbVersion": "1.x",
"url": "http://localhost:8086",
"rejectUnauthorized": true
}
]