nongxiaohe/pub.py

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

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 + '/100001'
	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


	#with open('test.png', 'w') as f:
		#f.writelines(data)

	"""
	handle = open('admin/static/images/banner.png', 'rb')
	img = handle.read(1)
	handle.close()
	data = struct.pack('c', img)
	print data
	"""
	#pub.push(key, value)

#sensor()
pic()