From f862b67c991d4cf914c2c8af49f332e6488946e6 Mon Sep 17 00:00:00 2001 From: xyj <10908227994@qq.com> Date: Thu, 7 Dec 2023 19:15:41 +0800 Subject: [PATCH] update --- MQTT.py | 11 +++++------ __pycache__/tool.cpython-310.pyc | Bin 0 -> 2521 bytes 2 files changed, 5 insertions(+), 6 deletions(-) create mode 100644 __pycache__/tool.cpython-310.pyc diff --git a/MQTT.py b/MQTT.py index d25cff5..b645e89 100644 --- a/MQTT.py +++ b/MQTT.py @@ -13,9 +13,6 @@ def on_connect(client, userdata, flags, rc): def valid(msg, client): - p = subprocess.Popen(['cat /home/pi/device_name'], shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) - out, err = p.communicate() - device_name = out.decode('utf-8') origin_data = json.loads(msg.payload.decode('utf-8')) if 'msg' not in origin_data: client.publish('error', payload='msg must be supplied', qos=0) @@ -23,7 +20,7 @@ def valid(msg, client): if 'device_name' not in origin_data: client.publish('error', payload='device_name must be supplied', qos=0) return False - if device_name.casefold() != origin_data['device_name'].casefold(): + if device_name != origin_data['device_name']: return False return True @@ -75,10 +72,12 @@ def exec_shutdown(): import os if __name__ == '__main__': - + p = subprocess.Popen(['cat /home/pi/device_name'], shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) + out, err = p.communicate() + device_name = out.decode('utf-8').strip() while True: try: - client = mqtt.Client(client_id='s') + client = mqtt.Client(client_id=device_name) client.username_pw_set("demo", "123456") # Specify callback function client.on_connect = on_connect diff --git a/__pycache__/tool.cpython-310.pyc b/__pycache__/tool.cpython-310.pyc new file mode 100644 index 0000000000000000000000000000000000000000..721a189231dbc2d60e9f87fa8c7e70bcf403f753 GIT binary patch literal 2521 zcmbVNOOM<{5O%j8>5xc!b1^KL?onWwGw+;AsMf`GvmpO+uPk< zWk;S9NQlE;;gZAdfy17VIB?;{&*&>Cf^%+>2vqg#DNB4Opaa%m zA?OBcvKHu&wOItZ$>!KG&@FbHodDftJ@-H~WSsF)iUyOKM=JBY!kr5o+dwkFV ze7E6yd>4dv2859wVH8^SWA2tWAvM`{cbqTjgihR=ZhOqzArr5524I;E294TdVA~dD zA!}~A1nvaqx0c2?#Pt z`g}MvfznJ=+G;N46Ti~;7H*n`s5luGWUR>KkvML}7eZjY_ra zn;;wJywHY}#zm`KFv$eaDl5I~$jfl{le^Qq4)cDR$IF{pKb50pDF!^#DlRv5Ule=Y zncflCydP^JhKuE@mLf=xec077d%*#ix~y@Zs;i*G`&7P( zkc4&<+8^6>Eg;X{I_(dF+6CB0Y;KEA;d?j+tp>S$dUhVUV8gfClpH&G(Oc;f>4A%FfTv;Yw&WQYF+TpH zB*sf(aT3KminAcPp>ap5C(lFMw1v!jd6C%5y4i@y3;5qFC@!M7gklCN z4gP>WgyGX2jzDVphZ{l%u?0{6Ty#AMylJtp+S2^16YcLYW2*v0R!Es#a2_x^DvTJ})** zDEWE?cvr?Ngid8#@3aVR!HfuvNiVj>j zH%$=MamJCa!`T&b?a|LWj~;&a=TARA`u^KLe*NVzIT$L}#?ft2fJgMg%4W&O=Tpoe zP{ndl#3IvNFHGy{_!aT5Ze(L2uYwITIly>WJLTIj1OCUjcmt6a z5(yz=6z_uQdh!iy+k_C}o(K(zc${UvCDk-WcVOC@*A6 zqwJwr{bUCPCIyMul?ZPeV7vOrkrpMkIE9~#1gnPp79wAvp&`%&Uh2`%4Vz&Y&WDY# H6@~u-V(n1C literal 0 HcmV?d00001