#!/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)