import pyodbc
conn = pyodbc.connect(dsn="hive", autocommit=True)
beg_dt = '2016-05-01'
end_dt = '2016-06-01'
mq = """
select
local_date,
hotel_id as exp_id,
sum(xclick) as xclick,
sum(pclick) as pclick,
sum(pcost_usd) as pcost,
sum(trx) as trx,
sum(gp_usd) as gp,
sum(bid_gp_usd) as bid_gp
from embid.bid_unit_kpi_agg
where local_date between ? and ?
and etl_processed_type = 'HOTEL'
and partner_org in ('TRIPADVISOR')
and partner_pos = 'US'
and brand = 'ORBITZ'
and device_type = 'MOBILE'
group by local_date, hotel_id
order by local_date, hotel_id
"""
ta_orb_mob_perf = pd.read_sql(mq, conn, params=[beg_dt, end_dt])
No comments:
Post a Comment