Python呼叫kylin介面實現業務
阿新 • • 發佈:2018-11-08
需求:
我這邊要實現每天點選最多的n個使用者,通過kylin介面寫sql,不支援max,所以改為呼叫kylin介面來實現,程式碼如下:
#!/usr/bin/env python # coding=utf-8 import sqlalchemy as sa def kylin_query_show(conn_str, query_sql): res_dic = {} kylin_engine = sa.create_engine(conn_str) results = kylin_engine.execute(query_sql) for line inresults: userid = str(line[0]).strip() datetime = line[1].strip() per_count = line[2] if datetime not in res_dic: res_dic[datetime] = [] res_dic[datetime].append((userid, per_count)) else: res_dic[datetime].append((userid, per_count))return res_dic if __name__ == "__main__": conn_str = "kylin://username:[email protected]:7070/database?version=v1" query_sql = "select userid, datetime, count(*) c from xxx_report group by userid, datetime" res_dic = kylin_query_show(conn_str, query_sql) tmp_list = [] for k, v inres_dic.items(): final_userid_count_list = sorted(v, key = lambda x: x[1], reverse=True) final_userid_count_list = final_userid_count_list[0:5] tmp_list.append((k, ','.join([':'.join([u_c[0], str(u_c[1])]) for u_c in final_userid_count_list]))) res = sorted(tmp_list, key = lambda x:x[0], reverse=True) for i in res: print "\t".join(i)