Thursday, June 2, 2016

Passing Query Parameters in Pandas


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