Graph / Map Display
Data storage
Automation / Remote control
Image Recognition / AI
Alert / Notification
API integration
Visualization of acquired values and data
You can visualize the value and data obtained from the sensor in graphs, charts and maps. Live or Historical view can be easily created.
// chart.js
var data = [], options = { chart: { type: 'line' }, series: [{ data }] }
var chart = new ApexCharts(document.querySelector("#chart"), options);
chart.render();
// connect to a device
var obniz = new Obniz("1234-5678");
obniz.repeat(async () => {
data.push(await obniz.ad0.getWait()) // get io0 voltage
chart.updateSeries([{ data }]) // update chart
}, 1000);
Data storage
Values and data from sensors can be saved to an internal server or an external database. You can save it to MySQL, for example, or to a Google spreadsheet. You can also perform real-time analytics with AWSKinesis.
const Obniz = require("obniz");
const Logtta_TH = Obniz.getPartsClass('Logtta_TH');
const kinesis = new require("aws-sdk").Kinesis();
// obniz setup
const obniz = new Obniz("1111-1111", {access_token: "YOUR_TOKEN"});
obniz.onconnect = async () => {
await obniz.ble.initWait();
obniz.ble.scan.onfind = async (peripheral) => {
// Connect Logtta BLE Temperature sensor
if (Logtta_TH.isDevice(peripheral)) {
const device = new Logtta_TH(peripheral);
await device.connectWait();
const temperature = await device.getTemperatureWait();
// Record to AWS Kinesis
const record = {
Data: JSON.stringify({ temperature }),
PartitionKey: "1",
StreamName: 'your-stream',
};
await kinesis.putRecord(record).promise();
}
};
await obniz.ble.scan.startWait();
}
Automation / Remote control
If a sensor value exceeds a threshold value, the motor is turned, or other errors, faults or abnormalities are detected. Real-time operation is possible at the time.
You can also set up a system to remotely reset devices and change their settings.
const Obniz = require("obniz");
const obnizList = {
"1111-1111": "Entrance",
"1111-1112": "On Exit door"
}
// Connect to all obniz
for (const obniz_id in obnizList) {
const obniz = new Obniz(obniz_id, {access_token: 'YOUR_TOKEN'});
obniz.onconnect = onconnect;
obniz.onclose = onclose
}
async function onconnect(obniz) {
// Call API when low voltage
obniz.ad0.start(async (voltage) => {
if(voltage < 1.2) {
await fetch(`http://example.com/voltages/${obniz.id}?voltage=${voltage}`);
}
});
}
Image Recognition / AI
By combining it with person detection, object recognition, and sex determination using deep learning such as Tensorflow, advanced alarm systems can be implemented in a short program.
const Obniz = require("obniz");
const cocoSsd = require('@tensorflow-models/coco-ssd');
const obniz = new Obniz("1111-1111", {access_token: "YOUR_TOKEN"});
obniz.onconnect = async () => {
// Load the model.
const model = await cocoSsd.load();
// Take a photo
const cam = obniz.wired("ArduCAMMini", { cs:0, mosi:1, miso:2, sclk:3, sda:6, scl:7 });
await cam.startupWait();
const img = await cam.takeWait('1024x768');
// Classify the image.
const predictions = await model.detect(img);
if (predictions[0].class === 'person') {
obniz.display.print("Found Person")
}
}
Alert / Notification
We'll send SMS notifications when the sensor value exceeds the threshold, as well as daily email notifications at regular intervals. Send alerts and notifications to email and SMS, such as.
const { WebClient } = require('@slack/client');
const Obniz = require("obniz");
const web = new WebClient("YOUR_SLACK_TOKEN");
// Connect to a device
const obniz = new Obniz("1234-5678");
await obniz.connectWait();
const sens = obniz.wired("HC-SR505", {vcc:0, signal:1, gnd:2});
// Send Slack message when found
sens.onchange = async (val) => {
await web.chat.postMessage({
channel: 'general',
text: 'Detect a Human'
});
}
API integration
You can build powerful IoT systems in the shortest time possible by integrating with AWS, Microsoft Azure, Google Cloud and any web service with REST APIs.
const Obniz = require("obniz");
const Logtta_TH = Obniz.getPartsClass('Logtta_TH');
const kinesis = new require("aws-sdk").Kinesis();
// obniz setup
const obniz = new Obniz("1111-1111", {access_token: "YOUR_TOKEN"});
obniz.onconnect = async () => {
await obniz.ble.initWait();
obniz.ble.scan.onfind = async (peripheral) => {
// Connect Logtta BLE Temperature sensor
if (Logtta_TH.isDevice(peripheral)) {
const device = new Logtta_TH(peripheral);
await device.connectWait();
const temperature = await device.getTemperatureWait();
// AWS Kinesisへ保存
const record = {
Data: JSON.stringify({ temperature }),
PartitionKey: "1",
StreamName: 'your-stream',
};
await kinesis.putRecord(record).promise();
}
};
await obniz.ble.scan.startWait();
}
