Commit e5abdf9b authored by 张彦钊's avatar 张彦钊

update dairyQueueUpdate file

parent 42c6fb7d
......@@ -11,10 +11,8 @@ def get_active_users():
now = datetime.now()
now_start = str(now)[:16] + ":00"
now_end = str(now)[:16] + ":59"
sql = "select device_id,city_id from user_active_time limit 10;"
# TODO 正式上线后用下面的sql语句
# sql = "select device_id,city_id from user_active_time " \
# "where active_time <= '{}' and active_time >= '{}'".format(now_end,now_start)
sql = "select device_id,city_id from user_active_time " \
"where active_time <= '{}' and active_time >= '{}'".format(now_end,now_start)
df = con_sql(sql)
if df.empty:
print("当下这一分钟没有活跃用户,不需要预测")
......@@ -46,8 +44,6 @@ def get_active_users():
print("没有尾号是6的用户,不需要预测")
else:
device_list = df["device_id"].values.tolist()
print("358035085192742" in device_list)
print("AB20292B-5D15-4C44-9429-1C2FF5ED26F6" in device_list)
city_list = df["city_id"].values.tolist()
device_city_list = list(zip(device_list, city_list))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment