sql获取包含变量的动态更新条件的数据

ruarlubt  于 2021-06-24  发布在  Hive
关注(0)|答案(0)|浏览(201)
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是三个长度相同的列表。
如何让它工作?谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题