comparison service/mqtt_to_rdf/tasks.py @ 732:fdddbdaf07b5

more service renaming; start a lot more serv.n3 job files Ignore-this: 635aaefc7bd2fa5558eefb8b3fc9ec75
author drewp@bigasterisk.com
date Thu, 06 Feb 2020 16:36:35 -0800
parents service/rdf_from_mqtt/tasks.py@edc14422f128
children 9ca69f2be87b
comparison
equal deleted inserted replaced
731:def4a53cbb6c 732:fdddbdaf07b5
1 from invoke import task, Collection
2
3 import sys
4 sys.path.append('/my/proj/release')
5 from serv_tasks import serv_tasks
6
7 ns = Collection()
8 serv_tasks(ns, 'serv.n3', 'mqtt_to_rdf')
9
10 @ns.add_task
11 @task
12 def tail_mqtt(ctx):
13 internal_mqtt_port = 10010
14 ctx.run(f'mosquitto_sub -h bang -p 1883 -d -v -t \#')