@@ -10,6 +10,7 @@ db_con_str = "mysql+pymysql://%s:%s@%s:%d/%s" % ("data", "hcst@2021", "139.186.2
engine = create_engine(db_con_str, connect_args={'charset': 'utf8'})
+
def send_request(account_id):
url = 'http://139.186.27.96:31012/ai_auto_creative'
request_data = json.dumps({"account_id": account_id})
@@ -22,6 +22,7 @@ def send_request(account_id):
unique_uuid = str(uuid.uuid4())
print("***********", "补满创意-Start, unique_uuid = ", unique_uuid, datetime.datetime.now(), "**************")
# 1、获取已有的账号
sql = """
select account_id from ctop_ai_kuaishou_advertiser_strategy where status = 1
@@ -17,6 +17,7 @@ def send_request(account_id):
return json.loads(request.text)
# 0、 打印该定时任务被调用的时间
print("***********", "高质量素材复建-Start, unique_uuid = ", unique_uuid, datetime.datetime.now(), "**************")
@@ -31,6 +31,7 @@ acc_df = pd.read_sql(sql, engine)
acc_list = [int(account_id) for account_id in acc_df['account_id'].unique()]
print(acc_list)
# 2、 5个账户一组进行发送请求
batch_num = 5
for i in range(0, len(acc_list), batch_num):
print("***********", "程序化高质量-Start, unique_uuid = ", unique_uuid, datetime.datetime.now(), "**************")
print("***********", "程序化上新-Start, unique_uuid = ", unique_uuid, datetime.datetime.now(), "**************")