5 import mongodb_store_msgs.srv
as dc_srv
6 import mongodb_store.util
as dc_util
7 from mongodb_store.message_store
import MessageStoreProxy
9 from datetime
import datetime
10 from task_executor
import task_routine, task_query
14 if __name__ ==
'__main__':
16 rospy.init_node(
"example_message_store_client")
19 msg_store = MessageStoreProxy(collection=
'task_events')
21 parser = argparse.ArgumentParser(description=
'Prints a summary of tasks executed within the queried time window.')
22 parser.add_argument(
'start', metavar=
'S', type=task_query.mkdatetime, nargs=
'?', default=task_routine.start_of_the_day(),
23 help=
'start datetime of query, defaults to the midnight just passed. Formatted "d/m/y H:M" e.g. "06/07/14 06:38"')
24 parser.add_argument(
'end', metavar=
'E', type=task_query.mkdatetime, nargs=
'?',
25 help=
'end datetime of query, defaults to no end. Formatted "d/m/y H:M" e.g. "06/07/14 06:38"')
28 args = parser.parse_args()
38 results = task_query.query_tasks(msg_store,
46 task_query.summarise(results)
49 except rospy.ServiceException, e:
50 print "Service call failed: %s"%e