------------------------------------------------------------ revno: 360 committer: Michal Hruby <michal....@gmail.com> branch nick: bluebird timestamp: Sat 2011-12-31 20:35:28 +0100 message: Add real-world query samples added: tools/development/query_sets/synapse-unlimited.txt tools/development/query_sets/synapse.txt modified: tools/development/query_timings.py
-- lp:zeitgeist https://code.launchpad.net/~zeitgeist/zeitgeist/bluebird Your team Zeitgeist Framework Team is subscribed to branch lp:zeitgeist. To unsubscribe from this branch go to https://code.launchpad.net/~zeitgeist/zeitgeist/bluebird/+edit-subscription
=== added file 'tools/development/query_sets/synapse-unlimited.txt' --- tools/development/query_sets/synapse-unlimited.txt 1970-01-01 00:00:00 +0000 +++ tools/development/query_sets/synapse-unlimited.txt 2011-12-31 19:35:28 +0000 @@ -0,0 +1,9 @@ +TimeRange.until_now(), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation="!"+Interpretation.SOFTWARE), Subject.new_for_values(interpretation="!"+Interpretation.FOLDER)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.until_now(), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.SOFTWARE)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.until_now(), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.AUDIO)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.until_now(), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.VIDEO)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.until_now(), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.IMAGE)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.until_now(), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.DOCUMENT)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.until_now(), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.WEBSITE)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.until_now(), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation="!"+Interpretation.WEBSITE)])], StorageState.Any, 96, ResultType.MostRecentOrigin +TimeRange.until_now(), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation="!"+Interpretation.WEBSITE),Subject.new_for_values(interpretation="!"+Interpretation.SOFTWARE),Subject.new_for_values(interpretation="!"+Interpretation.AUDIO),Subject.new_for_values(interpretation="!"+Interpretation.VIDEO),Subject.new_for_values(interpretation="!"+Interpretation.IMAGE),Subject.new_for_values(interpretation="!"+Interpretation.DOCUMENT)])], StorageState.Any, 96, ResultType.MostRecentSubjects === added file 'tools/development/query_sets/synapse.txt' --- tools/development/query_sets/synapse.txt 1970-01-01 00:00:00 +0000 +++ tools/development/query_sets/synapse.txt 2011-12-31 19:35:28 +0000 @@ -0,0 +1,9 @@ +TimeRange.from_timestamp(time.time()*1000-604800000*24), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation="!"+Interpretation.SOFTWARE), Subject.new_for_values(interpretation="!"+Interpretation.FOLDER)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.from_timestamp(time.time()*1000-604800000*24), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.SOFTWARE)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.from_timestamp(time.time()*1000-604800000*24), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.AUDIO)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.from_timestamp(time.time()*1000-604800000*24), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.VIDEO)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.from_timestamp(time.time()*1000-604800000*24), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.IMAGE)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.from_timestamp(time.time()*1000-604800000*24), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.DOCUMENT)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.from_timestamp(time.time()*1000-604800000*24), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation=Interpretation.WEBSITE)])], StorageState.Any, 96, ResultType.MostRecentSubjects +TimeRange.from_timestamp(time.time()*1000-604800000*24), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation="!"+Interpretation.WEBSITE)])], StorageState.Any, 96, ResultType.MostRecentOrigin +TimeRange.from_timestamp(time.time()*1000-604800000*24), [Event.new_for_values(subjects=[Subject.new_for_values(interpretation="!"+Interpretation.WEBSITE),Subject.new_for_values(interpretation="!"+Interpretation.SOFTWARE),Subject.new_for_values(interpretation="!"+Interpretation.AUDIO),Subject.new_for_values(interpretation="!"+Interpretation.VIDEO),Subject.new_for_values(interpretation="!"+Interpretation.IMAGE),Subject.new_for_values(interpretation="!"+Interpretation.DOCUMENT)])], StorageState.Any, 96, ResultType.MostRecentSubjects === modified file 'tools/development/query_timings.py' --- tools/development/query_timings.py 2011-12-31 00:22:58 +0000 +++ tools/development/query_timings.py 2011-12-31 19:35:28 +0000 @@ -32,7 +32,7 @@ from collections import defaultdict from zeitgeist.datamodel import TimeRange, StorageState, ResultType -from zeitgeist.datamodel import Event +from zeitgeist.datamodel import Event, Subject, Interpretation, Manifestation import benchmark as engine from cairoplot import vertical_bar_plot @@ -82,6 +82,7 @@ parser.add_option("--plot", dest="plot_files", metavar="DATA_FILE", action="append", type="str") parser.add_option("--type", dest="type", help="type of plot") + parser.add_option("--count", dest="count", help="number of execution of each query", type="int") (options, args) = parser.parse_args() assert not args return options @@ -153,6 +154,7 @@ existing_data = json.load(open(options.output)) else: existing_data = {} + num_queries = 50 if not options.count else options.count logging.basicConfig(level=logging.DEBUG) for query in get_query_set(options.queryset): args = eval(query) @@ -161,7 +163,7 @@ handler = QueryPlanHandler() logging.getLogger("").addHandler(handler) results = {} - for i in xrange (50): + for i in xrange (num_queries): t1 = time.time() temp = engine.find_events(*args) temp["overall"] = time.time() - t1 @@ -177,7 +179,7 @@ for key in temp.keys(): if key != "events": - results[key] = results[key]/50 + results[key] = results[key]/num_queries print (results.keys())
_______________________________________________ Mailing list: https://launchpad.net/~zeitgeist Post to : zeitgeist@lists.launchpad.net Unsubscribe : https://launchpad.net/~zeitgeist More help : https://help.launchpad.net/ListHelp