Files
@ 44558087d3f6
Branch filter:
Location: light9/bin/collector - annotation
44558087d3f6
2.8 KiB
text/plain
move out rdfdb-synced-graph
Ignore-this: eaa4209f7c83f2fbbb4372debc340bd4
Ignore-this: eaa4209f7c83f2fbbb4372debc340bd4
5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5a4e74f1e36a 5e76c8fd8a03 5a4e74f1e36a 5a4e74f1e36a 5e76c8fd8a03 5a4e74f1e36a 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 8863b4485fd4 8863b4485fd4 5e76c8fd8a03 5e76c8fd8a03 5a4e74f1e36a 5a4e74f1e36a 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5e76c8fd8a03 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5e76c8fd8a03 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5a4e74f1e36a 5e76c8fd8a03 5a4e74f1e36a 8863b4485fd4 5e76c8fd8a03 5e76c8fd8a03 5a4e74f1e36a 5a4e74f1e36a 8863b4485fd4 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5a4e74f1e36a 5a4e74f1e36a 8863b4485fd4 8863b4485fd4 8863b4485fd4 8863b4485fd4 8863b4485fd4 8863b4485fd4 8863b4485fd4 8863b4485fd4 8863b4485fd4 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 5e76c8fd8a03 | #!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()
|