nongxiaohe/pub.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
    demeter web
    name:pub.py
    author:rabin
"""
from demeter.mqtt import *
from demeter.tcp import *
import random
import time
import base64

def sensor():
	# 模拟设备数据
	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)

def pic():
	gateway = '10086'
	pub = Pub()
	key = 'pic/'
	key = 'pic/pic_'
	gateway = '/' + gateway + '/200001'
	with open('admin/static/images/banner.png', 'rb') as f:
		data = f.readlines()
		total = len(data)
		key = key + str(total) + '_'
		i = 0
		print key
		for value in data:
			k = key + str(i) + gateway
			pub.push(k, value)
			print k
			i = i+1

#sensor()
#pic()

def tcp_sensor():
	# 模拟设备数据
	gateway = '10086'
	def device():
		return str(random.randint(100000, 100010))
	def val():
		return str(random.randint(1, 50))

	hard = 'sensor'
	pubType = ('temperature', 'humidity')
	client = Client('0.0.0.0', 8000)
	while True:
		for v in pubType:
			key = hard+'/'+v+'/'+gateway+'/'+device()
			value = val()
			print 'key:' + key + ' value:' + value
			client.send(key+'|:|'+value)
		time.sleep(1)

def tcp_pic():
	gateway = '10086'
	client = Client('0.0.0.0', 8000)
	key = 'pic/'
	key = 'pic/pic_'
	gateway = '/' + gateway + '/200001'
	with open('admin/static/images/banner.png', 'rb') as f:
		data = f.readlines()
		total = len(data)
		key = key + str(total) + '_'
		i = 0
		#print key
		for value in data:
			k = key + str(i) + gateway
			#print value
			#print value
			print k
			client.send(k + '|:|' +value)
			#print k
			i = i+1
	client.close()

tcp_sensor()
#tcp_pic()