第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問(wèn)題,去搜搜看,總會(huì)有你想問(wèn)的

python Paho客戶端MQTT:寫入多個(gè)文件

python Paho客戶端MQTT:寫入多個(gè)文件

侃侃爾雅 2022-06-02 10:21:03
初始化一個(gè) MQTT 客戶端,連接到特定主題的 MQTT 代理,對(duì)于在該主題上接收到的每條消息,執(zhí)行一個(gè)函數(shù)調(diào)用以檢查消息中屬性的長(zhǎng)度是否大于 200,如果是,則查找陀螺儀讀數(shù): GyroX & 保存到文件確保文件大小保持小于 400MB,否則打開(kāi)一個(gè)新文件并開(kāi)始寫入。我想寫入多個(gè)文件,即根據(jù)大小將傳入的 json 消息發(fā)布到不同的文件,而不僅僅是一個(gè)文件。怎么做 ?任何幫助表示贊賞file_name='/tmp/gyro_256'+"_"+timestr+".csv"def on_message(client, userdata, message):  y = json.loads(message.payload)  v = (len(y['sec_data']))  p = int(v)  if p >= 200:          d = (y["sec_data"][10]["GyroX"])           with open(file_name,'a+') as f:                    f.write(d + "\n")client = mqttClient.Client("123")               #create new instanceclient.username_pw_set(user, password=password)    #set username and client.on_connect= on_connect                      #attach function to   client.on_message= on_message                      #attach function to    client.connect(broker_address,port,100) #connectclient.subscribe("tes1") #subscribeclient.loop_start() #then keep listening foreverif int(os.path.getsize(file_name)) > 47216840 :     client.loop_stop()     timestr = time.strftime("%Y%m%d%H%M%S")     file_name = '/vol/vol_HDB/data/gyro_256'+"_"+timestr+".csv"client.loop_start()
查看完整描述

1 回答

?
幕布斯6054654

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")


查看完整回答
反對(duì) 回復(fù) 2022-06-02
  • 1 回答
  • 0 關(guān)注
  • 123 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)