Send sensor data to Cloud Pub/Sub from a BeagleBone

beaglebone-pubsub.py

import time


# Cloud Pub/Sub ###########################
from google.cloud import pubsub

client = pubsub.PublisherClient()
topic = client.topic_path(PROJECT_ID, TOPIC_NAME)

def send_to_pubsub(message, data):
    client.publish(topic, message, userdata=data)
    print(message)  # just so we can see something happen in the terminal

    
# BeagleBone ###########################
import mraa

button = mraa.Gpio(71)
button.dir(mraa.DIR_IN)

def callback(userdata):
    data = bytes(userdata.read())  # convert to bytes for pubsub
    message = "interrupt triggered with userdata = {0}".format(data)
    send_to_pubsub(message, data)

while True:
    button.isr(mraa.EDGE_BOTH, callback, button)
    time.sleep(1)