add ssl handling
This commit is contained in:
parent
39329f549f
commit
e1402d34d4
@ -19,7 +19,11 @@ def main():
|
|||||||
Entry point for mqtt logger.
|
Entry point for mqtt logger.
|
||||||
'''
|
'''
|
||||||
logging.basicConfig(format=LOG_FORMAT, filename=OWN_LOG_FILE)
|
logging.basicConfig(format=LOG_FORMAT, filename=OWN_LOG_FILE)
|
||||||
conn = mqtt.Mqtt(hostname='localhost', subscribe=['#'])
|
conn = mqtt.Mqtt(hostname='localhost', port=8883,
|
||||||
|
ca_certs='/etc/letsencrypt/live/mqtt.blackfinn.de/chain.pem',
|
||||||
|
certfile='/etc/letsencrypt/live/mqtt.blackfinn.de/cert.pem',
|
||||||
|
keyfile='/etc/letsencrypt/live/mqtt.blackfinn.de/privkey.pem',
|
||||||
|
subscribe=['#'])
|
||||||
if conn.connect() is False:
|
if conn.connect() is False:
|
||||||
logging.error('couldn\'t connect...')
|
logging.error('couldn\'t connect...')
|
||||||
return 1
|
return 1
|
||||||
|
Loading…
x
Reference in New Issue
Block a user