Pushing data to Bytebeam

6min
This section talks about how to push the data from the device to the cloud. Data is pushed to the cloud in Streams﻿. 
To push data you need to write an application that connects to uplink over TCP and pushes data to it. Uplink then in turn pushes the data to the cloud over MQTT.
﻿
﻿
As an example, this guide assumes you are pushing temperature data to Bytebeam. 
Create a stream on the cloud
First, let us create a stream called temperature on the Bytebeam cloud.  First, go to  Bytebeam Cloud. Now, click on your username in the top right corner and navigate to the “Settings” section.
﻿
﻿
Next, select Streams and Click on "Create Stream".
﻿
Now, enter the stream name and column name. In this example, we have chosen the data type of temperature as Float64. Click on the "Submit" button.
﻿
The temperature stream should be visible under the "Streams" section.
﻿
Configuration on the device side
You can now write to uplink from your application. Below you can see samples for some popular languages.
﻿
demo.py
demo.js
demo.rs
demo.go
package main

import (
	"bufio"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"net"
	"strconv"
	"time"
)

func readCPUTemperature() float64 {
	data, err := ioutil.ReadFile("/sys/class/thermal/thermal_zone0/temp")
	if err != nil {
		fmt.Println("Error reading temperature:", err)
		return 0.0
	}
	tempStr := string(data)
	tempInt, err := strconv.Atoi(tempStr[:len(tempStr)-1])
	if err != nil {
		fmt.Println("Error parsing temperature:", err)
		return 0.0
	}
	return float64(tempInt) / 1000.0
}

func sendData(conn net.Conn, payload map[string]interface{}) {
	data, _ := json.Marshal(payload)
	fmt.Println(string(data))
	conn.Write(append(data, '\n'))
}

func main() {
	conn, err := net.Dial("tcp", "localhost:5050")
	if err != nil {
		fmt.Println("Error connecting:", err.Error())
		os.Exit(1)
	}
	defer conn.Close()

	fmt.Println("Starting Uplink Bridge App")
	sequence := 1
	for {
		time.Sleep(5 * time.Second)
		temp := readCPUTemperature()
		t := time.Now().UnixNano() / int64(time.Millisecond)
		payload := map[string]interface{}{
			"stream":    "temperature",
			"sequence":  sequence,
			"timestamp": t,
			"temp":      temp,
		}
		sendData(conn, payload)
		sequence++
	}
}
package main

import (
	"bufio"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"net"
	"strconv"
	"time"
)

func readCPUTemperature() float64 {
	data, err := ioutil.ReadFile("/sys/class/thermal/thermal_zone0/temp")
	if err != nil {
		fmt.Println("Error reading temperature:", err)
		return 0.0
	}
	tempStr := string(data)
	tempInt, err := strconv.Atoi(tempStr[:len(tempStr)-1])
	if err != nil {
		fmt.Println("Error parsing temperature:", err)
		return 0.0
	}
	return float64(tempInt) / 1000.0
}

func sendData(conn net.Conn, payload map[string]interface{}) {
	data, _ := json.Marshal(payload)
	fmt.Println(string(data))
	conn.Write(append(data, '\n'))
}

func main() {
	conn, err := net.Dial("tcp", "localhost:5050")
	if err != nil {
		fmt.Println("Error connecting:", err.Error())
		os.Exit(1)
	}
	defer conn.Close()

	fmt.Println("Starting Uplink Bridge App")
	sequence := 1
	for {
		time.Sleep(5 * time.Second)
		temp := readCPUTemperature()
		t := time.Now().UnixNano() / int64(time.Millisecond)
		payload := map[string]interface{}{
			"stream":    "temperature",
			"sequence":  sequence,
			"timestamp": t,
			"temp":      temp,
		}
		sendData(conn, payload)
		sequence++
	}
}
﻿
 If you do not see your favorite language do not worry. You can write to uplink in 2 easy steps:
Create a TCP socket and connect to  localhost and port 5050
Periodically write data in the below JSON format to the port (NOTE: newline delimited)
﻿
JSON
{
  "stream": "temperature",
  "sequence": 1,
  "timestamp": 1698806057153,
  "temp": 17.0,
}
{
  "stream": "temperature",
  "sequence": 1,
  "timestamp": 1698806057153,
  "temp": 17.0,
}
﻿
In the above JSON you need to auto-increment  the sequence for each packet and the timestamp needs to be in milliseconds
The temperature data should now be visible on the cloud. Head over to Bytebeam Cloud and go to Device Management -> Device tab. Now click on the device and Select "Show Streams".
Select "temperature" stream.
﻿
﻿
The temperature data should be visible on the cloud now.
﻿
﻿
Updated 23 Nov 2023
Did this page help you?
Connect to Bytebeam cloud
Customising device shadow