首页   注册   登录
 zy820 最近的时间轴更新

zy820

V2EX 第 303783 号会员,加入于 2018-03-27 15:34:11 +08:00
zy820 最近回复了
if __name__ == "__main__":
sensor_que = queue.Queue()
sensor_data = {'DeviceId': '', 'AirPressure': 0, 'Humidity': 0, 'Noise': 0, 'Pm25': 0, 'Temperature': 0,
'WindDirection': 0, 'WindSpeed': 0}
# HOST, PORT = "localhost", 9999 #windows
HOST, PORT = "0.0.0.0", 9999 # Linux
server = socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler) # 线程
server.serve_forever()
print('before init_db!')
connect_sql()
init_db()
print('after init_db!')
for i in range(multiprocessing.cpu_count()):
t = threading.Thread(target=getsensor_que)
t.start()
没有大神指点一下吗
def getsensor_que():
while True:
sensor = sensor_que.get(block=True) #阻塞,queue 为空时,不会 Queue.Empty 异常
print(sensor)
savetosql(sensor)

for i in range(multiprocessing.cpu_count()):
t = threading.Thread(target=getsensor_que)
t.start()
@msg7086 谢谢提醒,我的,目前根据六楼建议已解决
@copie 不是 websocket 吧,就是 tcp server 端,目前已经接收数据了,下一步存储到数据库
@msg7086 \x00\x00\x03\xe9 四个字节是一个 int 啊,现在接收要把它转化过来
@misaka19000 我觉得也是正在尝试
@imn1 [0]返回的是 int 啊
@GeruzoniAnsasu data=struct.unpack(">ii",b"\x00\x00\x00\x1e")[0] 加个 i 就行了,现在还是保存字节流并提取想要位置的字节问题
@GeruzoniAnsasu data=struct.unpack(">i",b"\x00\x00\x00\x1e")[0]只能有四个字节,现在问题时怎么把 b''字节流保存并截取我想要的字节呢
关于   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   2121 人在线   最高记录 3821   ·  
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.1 · 11ms · UTC 00:36 · PVG 08:36 · LAX 16:36 · JFK 19:36
♥ Do have faith in what you're doing.
沪ICP备16043287号-1