队列处理完扔到另外一个队列进行处理
This commit is contained in:
1 parent
b1fb8fa7a0
commit
fa32886fb2
1 file changed
+12
@@ -176,6 +176,18 @@ def team_check(r):
|
||||
shutil.rmtree(os.path.join(workdir, 'print', pid,orderId), ignore_errors=True)
|
||||
print(time.strftime('%Y-%m-%d %H:%M:%S', time.localtime()), f'pid:{pid} 生成团队审核模型 end')
|
||||
|
||||
#塞入队列进行处理 , SADD 方式插入
|
||||
queueData = {
|
||||
'pid': pid,
|
||||
'order_id': orderId,
|
||||
'shop_id': shopId,
|
||||
'oss_path': ossPath,
|
||||
}
|
||||
r.sadd('model:adjust_image_color', json.dumps(queueData))
|
||||
|
||||
|
||||
|
||||
|
||||
def get_p3d_info(pid):
|
||||
url = "https://mp.api.suwa3d.com/api/customerP3dLog/info?id="+pid
|
||||
res = requests.get(url)
|
||||
|
||||
Reference in new issue
Block a user