Mercurial > code > home > repos > light9
view bin/collector @ 1345:13f758eda3b4
refactor rdfdb: sendGraphToClient
Ignore-this: 77dc47e091494adabca4cf04173547de
author | Drew Perttula <drewp@bigasterisk.com> |
---|---|
date | Sun, 05 Jun 2016 00:49:15 +0000 |
parents | 8863b4485fd4 |
children | f427801da9f6 |
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 from light9.rdfdb.syncedgraph import SyncedGraph from light9.rdfdb import clientsession 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 launch(graph): # todo: drive outputs with config files outputs = [EnttecDmx(L9['output/dmx0/'], 100, '/dev/dmx0'), Udmx(L9['output/udmx/'], 100)] c = Collector(graph, 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) def main(): log.setLevel(logging.DEBUG) graph = SyncedGraph(networking.rdfdb.url, "collector") graph.initiallySynced.addCallback(lambda _: launch(graph)) reactor.run() if __name__ == '__main__': main()