nongxiaohe/pub.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
    demeter web
    name:pub.py
    author:rabin
"""
from mqtt.pub import *
import random
import time
# 模拟设备数据
gateway = '10086'
def device():
	return str(random.randint(100000, 100010))
def val():
	return str(random.randint(1, 50))

hard = 'sensor'
pubType = ('temperature', 'humidity')
pub = Pub()
while True:
	for v in pubType:
		key = hard+'/'+v+'/'+gateway+'/'+device()
		value = val()
		print 'key:' + key + ' value:' + value
		pub.push(key, value)
	time.sleep(1)