Mercurial > code > home > repos > homeauto
comparison 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 |
comparison
equal
deleted
inserted
replaced
717:e9d9b8506cb3 | 718:edc14422f128 |
---|---|
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', 'rdf_from_mqtt') | |
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 \#') |