|
|
@@ -76,6 +76,7 @@ def dw_order_channel_sync_ck(ymd):
|
|
|
i[8]=str(i[8])
|
|
|
i[11]=str(i[11])
|
|
|
i[15]=str(i[15])
|
|
|
+ i[-1]='' if i[-1]==None else i[-1]
|
|
|
data1.append(tuple(i))
|
|
|
ck.execute(f"alter table {table} drop partition '{ymd}' ")
|
|
|
ck.insertMany(f"{table}", col, tuple(data1))
|
|
|
@@ -84,6 +85,7 @@ def dw_order_channel_sync_ck(ymd):
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
- for i in dt.getDateLists('2019-03-18','2020-12-17'):
|
|
|
- # order(i)
|
|
|
- dw_order_channel_sync_ck(i)
|
|
|
+ dw_order_channel_sync_ck(dt.get_n_days(-2))
|
|
|
+ # for i in dt.getDateLists('2019-03-18','2020-12-17'):
|
|
|
+ # # order(i)
|
|
|
+ # dw_order_channel_sync_ck(i)
|
