diff service/rdf_from_mqtt/tasks.py @ 718:edc14422f128

add rdf_from_mqtt, though at the moment the graph urls may not be in sync and the reqs have just been updated Ignore-this: 11b16f06340adc7228930f3774323d1a
author drewp@bigasterisk.com
date Tue, 04 Feb 2020 23:33:21 -0800
parents
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/service/rdf_from_mqtt/tasks.py	Tue Feb 04 23:33:21 2020 -0800
@@ -0,0 +1,14 @@
+from invoke import task, Collection
+
+import sys
+sys.path.append('/my/proj/release')
+from serv_tasks import serv_tasks
+
+ns = Collection()
+serv_tasks(ns, 'serv.n3', 'rdf_from_mqtt')
+
+@ns.add_task
+@task
+def tail_mqtt(ctx):
+    internal_mqtt_port = 10010
+    ctx.run(f'mosquitto_sub -h bang -p 1883 -d -v -t \#')