Scans for BLE devices and publishes found devices to nsq topic.

blescan2nsq.py

from bluepy.btle import Scanner, DefaultDelegate
import json
import time
import gnsq

nsq = gnsq.Producer('127.0.0.1:4150')
nsq.start()

class ScanDelegate(DefaultDelegate):
    def __init__(self):
        DefaultDelegate.__init__(self)

    def handleDiscovery(self, dev, isNewDev, isNewData):
        output = {'ts': time.time(), 'rssi': dev.rssi, 'mac': dev.addr}

        for (adtype, desc, value) in dev.getScanData():
	    #if desc in ["Complete Local Name"]:
                output[desc.replace(" ", "")] = value;

        jsonOut = json.dumps(output)
        nsq.publish('bluetooth', jsonOut)

scanner = Scanner().withDelegate(ScanDelegate())
devices = scanner.scan(0)