mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Add -r argument for retaining publish

pull/8/head
Nico 2015-11-05 22:36:00 +01:00
rodzic 31734ce28f
commit 2d40c92811
1 zmienionych plików z 4 dodań i 4 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

8
scripts/pub_script.py
Wyświetl plik

@ -7,7 +7,7 @@ hbmqtt_pub - MQTT 3.1.1 publisher
Usage: Usage:
hbmqtt_pub --version hbmqtt_pub --version
hbmqtt_pub (-h | --help) hbmqtt_pub (-h | --help)
hbmqtt_pub --url BROKER_URL -t TOPIC (-f FILE | -l | -m MESSAGE | -n | -s) [-c CONFIG_FILE] [-i CLIENT_ID] [-q | --qos QOS] [-d] [-k KEEP_ALIVE] [--clean-session] [--ca-file CAFILE] [--ca-path CAPATH] [--ca-data CADATA] [ --will-topic WILL_TOPIC [--will-message WILL_MESSAGE] [--will-qos WILL_QOS] [--will-retain] ] hbmqtt_pub --url BROKER_URL -t TOPIC (-f FILE | -l | -m MESSAGE | -n | -s) [-c CONFIG_FILE] [-i CLIENT_ID] [-q | --qos QOS] [-d] [-k KEEP_ALIVE] [--clean-session] [--ca-file CAFILE] [--ca-path CAPATH] [--ca-data CADATA] [ --will-topic WILL_TOPIC [--will-message WILL_MESSAGE] [--will-qos WILL_QOS] [--will-retain] ] [-r]
Options: Options:
-h --help Show this screen. -h --help Show this screen.
@ -16,6 +16,7 @@ Options:
-c CONFIG_FILE Broker configuration file (YAML format) -c CONFIG_FILE Broker configuration file (YAML format)
-i CLIENT_ID Id to use as client ID. -i CLIENT_ID Id to use as client ID.
-q | --qos QOS Quality of service to use for the message, from 0, 1 and 2. Defaults to 0. -q | --qos QOS Quality of service to use for the message, from 0, 1 and 2. Defaults to 0.
-r Set retain flag on connect
-t TOPIC Message topic -t TOPIC Message topic
-m MESSAGE Message data to send -m MESSAGE Message data to send
-f FILE Read file by line and publish message for each line -f FILE Read file by line and publish message for each line
@ -73,7 +74,7 @@ def _get_message(arguments):
for line in f: for line in f:
yield line.encode(encoding='utf-8') yield line.encode(encoding='utf-8')
except: except:
logger.error("%s Failed to read file '%s'" % (client.client_id, arguments['-f'])) logger.error("Failed to read file '%s'" % arguments['-f'])
if arguments['-l']: if arguments['-l']:
import sys import sys
for line in sys.stdin: for line in sys.stdin:
@ -87,7 +88,6 @@ def _get_message(arguments):
yield message yield message
@asyncio.coroutine @asyncio.coroutine
def do_pub(client, arguments): def do_pub(client, arguments):
@ -103,7 +103,7 @@ def do_pub(client, arguments):
topic = arguments['-t'] topic = arguments['-t']
for message in _get_message(arguments): for message in _get_message(arguments):
logger.info("%s Publishing to '%s'" % (client.client_id, topic)) logger.info("%s Publishing to '%s'" % (client.client_id, topic))
yield from client.publish(topic, message, qos) yield from client.publish(topic, message, qos, arguments['-r'])
yield from client.disconnect() yield from client.disconnect()
logger.info("%s Disconnected from broker" % client.client_id) logger.info("%s Disconnected from broker" % client.client_id)
except KeyboardInterrupt: except KeyboardInterrupt: