物聯網MQTT協議之mosquitto

略

mosquitto_pub # 訊息發布

mosquitto_sub # 訊息訂閱

mosquitto_sub *** >> test.csv

import json

import pymysql
import os
import time
defreadfile
(row)
:with
open
('test.csv'
,'r')as
file
: rowed = row #記錄上次讀取的行數
for n,i in
enumerate
(file):
print
(n)if ncontinue
print
(i.strip(
'\n'))
data =
eval
(i.strip(
'\n'))
id=data[0]
cursor.execute(
'select id from testdata_test'
) ids = cursor.fetchall(
) ids =
[x['id'
]for x in ids]
ifid
in ids:
print
("zai"
) cursor.execute(
'update testdata_test set no={},name="what",age={} where id={}'
.format
(data[1]
,data[3]
,data[0]
))print
("更新完成！"
)else
: cursor.execute(
'insert into testdata_test values({},{},"{}",{})'
.format
(data[0]
,data[1]
,data[2]
,data[3]
))print
("新增完成！"
) row = n
time.sleep(5)
readfile(row)
config =
conn = pymysql.connect(
**config)
conn.autocommit(1)
cursor = conn.cursor(
)#關閉游標

物聯網協議之 MQTT協議

mqtt協議 message queuing telemetry transport 遙信訊息佇列傳輸，是ibm公司於1999年提出的，現在最新版本是3.1.1。mqtt是乙個基於tcp的發布訂閱協議，設計的初始目的是為了極有限的記憶體裝置和網路頻寬很低的網路不可靠的通訊，非常適合物聯網通訊。如上圖...

物聯網傳輸協議MQTT

mqtt是乙個物聯網傳輸協議，它被設計用於輕量級的發布 訂閱式訊息傳輸，旨在為低頻寬和不穩定的網路環境中的物聯網裝置提供可靠的網路服務。mqtt是專門針對物聯網開發的輕量級傳輸協議。mqtt協議針對低頻寬網路，低計算能力的裝置，做了特殊的優化，使得其能適應各種物聯網應用場景。目前mqtt擁有各種平台...

物聯網傳輸協議MQTT

mqtt是乙個物聯網傳輸協議，它被設計用於輕量級的發布 訂閱式訊息傳輸，旨在為低頻寬和不穩定的網路環境中的物聯網裝置提供可靠的網路服務。mqtt是專門針對物聯網開發的輕量級傳輸協議。mqtt協議針對低頻寬網路，低計算能力的裝置，做了特殊的優化，使得其能適應各種物聯網應用場景。目前mqtt擁有各種平台...