nikdoof/aaisp2mqtt
1
0
Fork 0
mirror of https://github.com/nikdoof/aaisp2mqtt.git synced 2025-12-14 10:12:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

allow 100 in flight messages

Browse Source
This commit is contained in:
Nat Morris
2016-11-16 02:46:25 +00:00
parent c37d81737b
commit 25f27fd5b0
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
aaisp-to-mqtt.py
View File

@@ -4,6 +4,7 @@ import sys
import logging import logging
import json import json
import urllib import urllib
import time
import configparser import configparser
import paho.mqtt.client as mqtt import paho.mqtt.client as mqtt
import humanfriendly import humanfriendly
@@ -69,6 +70,7 @@ def main():
# do auth? # do auth?
if mqtt_username is not None and mqtt_password is not None: if mqtt_username is not None and mqtt_password is not None:
client.username_pw_set(mqtt_username, mqtt_password) client.username_pw_set(mqtt_username, mqtt_password)
client.max_inflight_messages_set(100)
client.connect(mqtt_broker, mqtt_port, 60) client.connect(mqtt_broker, mqtt_port, 60)
LOG.info("Connected OK to MQTT") LOG.info("Connected OK to MQTT")
@@ -97,7 +99,7 @@ def publish_per_circuit(client, circuit, mqtt_topic_prefix):
up = float(circuit["rx_rate"]) up = float(circuit["rx_rate"])
up_mb = round(up / 1000000, 2) up_mb = round(up / 1000000, 2)
down = float(circuit["tx_rate"]) down = float(circuit["tx_rate"])
down_mb = round(up / 1000000, 2) down_mb = round(down / 1000000, 2)
# line_prefix = "%s/line/%s" % (mqtt_topic_prefix, circuit["ID"]) # line_prefix = "%s/line/%s" % (mqtt_topic_prefix, circuit["ID"])
login_prefix = "%s/login/%s" % (mqtt_topic_prefix, circuit["login"]) login_prefix = "%s/login/%s" % (mqtt_topic_prefix, circuit["login"])
@@ -122,6 +124,7 @@ def publish_per_circuit(client, circuit, mqtt_topic_prefix):
return return
def publish(client, topic, payload): def publish(client, topic, payload):
time.sleep(0.1)
result = client.publish(topic=topic, payload=payload, qos=1) result = client.publish(topic=topic, payload=payload, qos=1)
if result[0] != 0: if result[0] != 0:
LOG.fail("MQTT publish failure: %s %s" , topic, payload) LOG.fail("MQTT publish failure: %s %s" , topic, payload)