Mercurial > code > home > repos > light9
view bin/collector @ 1305:1f3e105a893c
predicate_objects support on SyncedGraph
Ignore-this: 9c2f3642e0601a9712c5c0ede8e9cc16
author | Drew Perttula <drewp@bigasterisk.com> |
---|---|
date | Mon, 30 May 2016 21:41:01 +0000 |
parents | 5a4e74f1e36a |
children | 8863b4485fd4 |
line wrap: on
line source
#!bin/python from __future__ import division from rdflib import Graph, URIRef, Literal from twisted.internet import reactor from twisted.web.server import Site from txzmq import ZmqEndpoint, ZmqFactory, ZmqPullConnection import json import logging import klein from greplin import scales from greplin.scales.twistedweb import StatsResource from run_local import log from light9.collector.output import EnttecDmx, Udmx from light9.collector.collector import Collector from light9.namespaces import L9 from light9 import networking class WebServer(object): stats = scales.collection('/webServer', scales.PmfStat('setAttr')) app = klein.Klein() def __init__(self, collector): self.collector = collector @app.route('/attrs', methods=['PUT']) def putAttrs(self, request): with WebServer.stats.setAttr.time(): body = json.load(request.content) settings = [] for device, attr, value in body['settings']: settings.append((URIRef(device), URIRef(attr), Literal(value))) self.collector.setAttrs(body['client'], body['clientSession'], settings) request.setResponseCode(202) @app.route('/stats', methods=['GET']) def getStats(self, request): return StatsResource('collector') def startZmq(port, collector): stats = scales.collection('/zmqServer', scales.PmfStat('setAttr')) zf = ZmqFactory() e = ZmqEndpoint('bind', 'tcp://*:%s' % port) s = ZmqPullConnection(zf, e) def onPull(message): with stats.setAttrZmq.time(): # todo: new compressed protocol where you send all URIs up # front and then use small ints to refer to devices and # attributes in subsequent requests. message[0] collector.setAttrs() s.onPull = onPull def main(): log.setLevel(logging.DEBUG) config = Graph() # todo: replace with rdfdb's loaded graph, and notice changes config.parse('show/dance2016/output.n3', format='n3') # todo: drive outputs with config files outputs = [EnttecDmx(L9['output/dmx0/'], 100, '/dev/dmx0'), Udmx(L9['output/udmx/'], 100)] c = Collector(config, outputs) server = WebServer(c) startZmq(networking.collectorZmq.port, c) reactor.listenTCP(networking.collector.port, Site(server.app.resource()), interface='::') log.info('serving http on %s, zmq on %s', networking.collector.port, networking.collectorZmq.port) reactor.run() if __name__ == '__main__': main()