| 12345678910111213141516171819202122232425262728293031323334353637383940 |
- """
- 数据同步到ck
- 天调度
- """
- from model.DataBaseUtils import MysqlUtils,CkUtils
- from model.DateUtils import DateUtils
- from model.log import logger
- log=logger()
- db = MysqlUtils()
- ck = CkUtils()
- dt = DateUtils()
- def sync_campaign(ymd):
- table = 'daily_vx_campaign'
- sql = 'select * from ' + table + ' where date="{} 00:00:00" '.format(ymd)
- data = db.quchen_text.getData(sql)
- data1 = []
- for i in data:
- li = list(i)
- li[1] = str(li[1])
- li[5] = round(li[5], 4)
- li[6] = round(li[6], 4)
- li[7] = round(li[7], 4)
- li[8] = round(li[8], 4)
- li[12] = round(li[12], 4)
- li[13] = round(li[13], 4)
- li[15] = round(li[15], 4)
- data1.append(tuple(li))
- col = db.quchen_text.getColumn("daily_vx_campaign")
- ck.execute("alter table order drop partition '{}' ".format(ymd))
- ck.insertMany(table, col, tuple(data1))
- def run(ymd):
- sync_campaign(ymd)
- if __name__ == '__main__':
- ymd=dt.get_n_days(-1)
- run(ymd)
|
