from pyhive import hive
cursor = hive.connect('XXX.XX.XX.XX').cursor()
import pandas as pd
def to_df(sql):
cursor.execute(sql)
return pd.DataFrame(cursor.fetchall() , columns=[x[0] for x in cursor.description])
sql = '''
select eventtype, count(truckid)
from ods_intelli_truck.ods_intelli_truck_video_event_list_i_p_daily
where
starttime > ({start_time})
and starttime< ({end_time})
and truckid in ({truck_id})
group by eventtype
limit 10
'''.format(truck_id = truck_id, start_time = start_time, end_time = end_time)
我希望从这个数据库“ods\u intelli\u truck.ods\u intelli\u truck\u video\u event\u list\u i\u p\u daily”中选择数据,条件动态变化,开始时间、结束时间和truki\u id。开始时间、结束时间和truki\u id是三个长度相同的列表。
如何让它工作?谢谢
暂无答案!
目前还没有任何答案,快来回答吧!