1 回答

TA貢獻(xiàn)1876條經(jīng)驗(yàn) 獲得超7個(gè)贊
第一次調(diào)用之后的任何代碼client.loop_start()都不會(huì)運(yùn)行,因?yàn)樵撜{(diào)用永遠(yuǎn)阻塞。
如果要更改文件名,則必須在on_message回調(diào)中進(jìn)行文件大小測(cè)試。
def on_message(client, userdata, message):
global filename
y = json.loads(message.payload)
v = (len(y['sec_data']))
p = int(v)
if int(os.path.getsize(file_name)) > 47216840 :
timestr = time.strftime("%Y%m%d%H%M%S")
file_name = '/vol/vol_HDB/data/gyro_256'+"_"+timestr+".csv"
if p >= 200:
d = (y["sec_data"][10]["GyroX"])
with open(file_name,'a+') as f:
f.write(d + "\n")
添加回答
舉報(bào)