equal
deleted
inserted
replaced
25 ts_list_count = query.scalar() |
25 ts_list_count = query.scalar() |
26 return 'Nb of tweets ' + str(ts_list_count) |
26 return 'Nb of tweets ' + str(ts_list_count) |
27 |
27 |
28 @app.route('/total/<int:since>', methods=['GET']) |
28 @app.route('/total/<int:since>', methods=['GET']) |
29 def total(since): |
29 def total(since): |
30 sincetime = datetime.fromtimestamp(since) |
30 sincetime = datetime.fromtimestamp(since - 3600) # Hack rapide car les horaires sont enregistres en mode naif dans la bdd |
31 delta_td = datetime.now() - sincetime |
31 delta_td = datetime.now() - sincetime |
32 delta_s = delta_td.total_seconds() |
32 delta_s = delta_td.total_seconds() |
33 query = db.session.query(func.count(Tweet.id)).filter(Tweet.created_at >= sincetime) #@UndefinedVariable |
33 query = db.session.query(func.count(Tweet.id)).filter(Tweet.created_at >= sincetime) #@UndefinedVariable |
34 ts_list_count = query.scalar() |
34 ts_list_count = query.scalar() |
35 res = { |
35 res = { |
39 } |
39 } |
40 return jsonpwrap(res) |
40 return jsonpwrap(res) |
41 |
41 |
42 @app.route('/podium/<int:since>/<tokens>', methods=['GET']) |
42 @app.route('/podium/<int:since>/<tokens>', methods=['GET']) |
43 def podium(since, tokens): |
43 def podium(since, tokens): |
44 sincetime = datetime.fromtimestamp(since) |
44 sincetime = datetime.fromtimestamp(since - 3600) # Hack rapide car les horaires sont enregistres en mode naif dans la bdd |
45 token_list = tokens.split(",") |
45 token_list = tokens.split(",") |
46 query_base = db.session.query(func.count(Tweet.id)).filter(Tweet.created_at >= sincetime) #@UndefinedVariable |
46 query_base = db.session.query(func.count(Tweet.id)).filter(Tweet.created_at >= sincetime) #@UndefinedVariable |
47 podium_res = {} |
47 podium_res = {} |
48 for token in token_list: |
48 for token in token_list: |
49 query = query_base.filter(Tweet.text.op('~*')(token)) #@UndefinedVariable |
49 query = query_base.filter(Tweet.text.op('~*')(token)) #@UndefinedVariable |