Mercurial > code > home > repos > homeauto

comparison service/reasoning/reasoning.py @ 1403:69b3f5b3aeda

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
comments and logging Ignore-this: 75df9bd5008caef0fd53eaa811f1500a darcs-hash:8d054c76bd9180e8f13b0a84bc7817e3937ed79a
author drewp <drewp@bigasterisk.com>
date Tue, 23 Jul 2019 10:16:59 -0700
parents ac127fdace62
children 62171aa2bc4e
comparison
equal deleted inserted replaced
1402:5373c5cc03c4 1403:69b3f5b3aeda
17 from crochet import no_setup 17 from crochet import no_setup
18 no_setup() 18 no_setup()
19 19
20 import json, time, traceback, sys 20 import json, time, traceback, sys
21 from logging import getLogger, DEBUG, WARN 21 from logging import getLogger, DEBUG, WARN
22 sys.path.append('/opt') # docker is putting lib/ here
23 22
24 from colorlog import ColoredFormatter 23 from colorlog import ColoredFormatter
25 from docopt import docopt 24 from docopt import docopt
26 from rdflib import Namespace, Literal, RDF, Graph 25 from rdflib import Namespace, Literal, RDF, Graph
27 from twisted.internet import reactor, task, defer 26 from twisted.internet import reactor, task, defer
33 32
34 from inference import infer, readRules 33 from inference import infer, readRules
35 from actions import Actions 34 from actions import Actions
36 from inputgraph import InputGraph 35 from inputgraph import InputGraph
37 from escapeoutputstatements import unquoteOutputStatements 36 from escapeoutputstatements import unquoteOutputStatements
38 37
39 from standardservice.logsetup import log 38 from standardservice.logsetup import log, verboseLogging
40 39
41 40
42 ROOM = Namespace("http://projects.bigasterisk.com/room/") 41 ROOM = Namespace("http://projects.bigasterisk.com/room/")
43 DEV = Namespace("http://projects.bigasterisk.com/device/") 42 DEV = Namespace("http://projects.bigasterisk.com/device/")
44 43
269 cyclone.web.Application.__init__(self, handlers, reasoning=reasoning) 268 cyclone.web.Application.__init__(self, handlers, reasoning=reasoning)
270 269
271 def configLogging(arg): 270 def configLogging(arg):
272 log.setLevel(WARN) 271 log.setLevel(WARN)
273 272
274 if arg['-i'] or arg['-r'] or arg['-o']: 273 if arg['-i'] or arg['-r'] or arg['-o'] or arg['-v']:
275 log.handlers[0].setFormatter(ColoredFormatter("%(log_color)s%(levelname)-8s %(name)-6s %(filename)-12s:%(lineno)-3s %(funcName)-20s%(reset)s %(white)s%(message)s", 274 log.handlers[0].setFormatter(ColoredFormatter("%(log_color)s%(levelname)-8s %(name)-6s %(filename)-12s:%(lineno)-3s %(funcName)-20s%(reset)s %(white)s%(message)s",
276 datefmt=None, 275 datefmt=None,
277 reset=True, 276 reset=True,
278 log_colors={ 277 log_colors={
279 'DEBUG': 'cyan', 278 'DEBUG': 'cyan',
302 Usage: reasoning.py [options] 301 Usage: reasoning.py [options]
303 302
304 -i Verbose log on the input phase 303 -i Verbose log on the input phase
305 -r Verbose log on the reasoning phase and web stuff 304 -r Verbose log on the reasoning phase and web stuff
306 -o Verbose log on the actions/output phase 305 -o Verbose log on the actions/output phase
306 -v Everywhere verbose
307 """) 307 """)
308 308
309 r = Reasoning() 309 r = Reasoning()
310 configLogging(arg) 310 configLogging(arg)
311 reactor.listenTCP(9071, Application(r), interface='::') 311 reactor.listenTCP(9071, Application(r), interface='::')