2 HCE project, Python bindings, Distributed Crawler application. 3 SitesManager object functional tests. 6 @author bgv bgv.hce@gmail.com 7 @link: http://hierarchical-cluster-engine.com/ 8 @copyright: Copyright © 2013-2014 IOIX Ukraine 9 @license: http://hierarchical-cluster-engine.com/license/ 27 if __name__ ==
"__main__":
28 logger = logging.getLogger(DC_CONSTS.LOGGER_NAME)
29 ch = logging.StreamHandler(sys.stdout)
30 ch.setLevel(logging.DEBUG)
31 logger.setLevel(logging.DEBUG)
32 formatter = logging.Formatter(
'%(asctime)s - %(thread)ld - %(threadName)s - %(name)s - %(funcName)s - %(levelname)s - %(message)s')
33 ch.setFormatter(formatter)
36 if __name__ ==
"__main__":
38 TEST_TITLE_OBJECT =
" object:\n" 42 CONFIG_SECTION =
"SitesManager" 43 config = ConfigParser.RawConfigParser()
44 config.add_section(CONFIG_SECTION)
45 config.set(CONFIG_SECTION,
"server", CONFIG_SECTION)
46 config.set(CONFIG_SECTION,
"DRCEHost",
"localhost")
47 config.set(CONFIG_SECTION,
"DRCEPort",
"5656")
48 config.set(CONFIG_SECTION,
"DRCETimeout",
"5000")
49 config.set(CONFIG_SECTION,
"DRCEDBAppName",
"cd api/python/bin && ./db-task.py")
57 adminServerConnection = connectionBuilderLight.build(TRANSPORT_CONSTS.SERVER_CONNECT,
58 BaseServerManager.ADMIN_CONNECT_ENDPOINT)
65 print TEST_TITLE + sm.__class__.__name__ + TEST_TITLE_OBJECT, vars(sm)
67 sm.setName(sm.__class__.__name__)
73 print "type(siteStatus)=" + str(
type(siteStatus))
74 event = eventBuilder.build(DC_CONSTS.EVENT_TYPES.SITE_STATUS, siteStatus)
75 event.connect_name = sm.serverName
77 sm.onEventsHandler(event)
78 print "ExecuteTask event sent" 82 print "Stopped after" + str(TTL) +
" sec of run!"
Class hides routines of bulding connection objects.