python - python sql获取具有动态更新条件的数据，包括变量

Question

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_intelli_truck.ods_intelli_truck_video_event_list_i_p_daily'中选择数据，动态变化的条件，start_time，end_time和truki_id。start_time、end_time 和 truki_id 是三个长度相同的列表。

如何使它工作？多谢

标签： pythonsqlhive