You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
52 lines
1.8 KiB
52 lines
1.8 KiB
import platform,sys,redis,time,requests,json,atexit |
|
sys.path.append('../libs/') |
|
|
|
import config,libs,libs_db_temp,common |
|
import oss2,os |
|
|
|
|
|
# 将本地文件上传到oss 中，并且清除 oss 上的文件 |
|
|
|
#文件存储lua路径 |
|
typeV = "print" |
|
filePath = f"G://obj_fix/{typeV}" |
|
ossPrefix = f"objs/{typeV}" |
|
def readTask(): |
|
startTimeTask = time.time() |
|
#读取数据库的任务 |
|
# pid = libs_db_temp.get_task_by_status(100) #2 表示该文件已经处理好了 |
|
# pid = str(pid) |
|
pid = "4417" |
|
if int(pid) == 0: |
|
print(f'{time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())}: 无任务,延时10s') |
|
time.sleep(10) |
|
return |
|
#检测文件是否存在 |
|
if not os.path.exists(f"{filePath}/{pid}/{pid}.obj"): |
|
print(f'{time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())}: {pid} Error: {filePath}/{pid}/{pid}.obj does not exist.') |
|
return False |
|
|
|
if not os.path.exists(f"{filePath}/{pid}/{pid}Tex1.jpg"): |
|
print(f'{time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())}: {pid} Error: {filePath}/{pid}/{pid}.obj does not exist.') |
|
return False |
|
|
|
if not os.path.exists(f"{filePath}/{pid}/{pid}.mtl"): |
|
print(f'{time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())}: {pid} Error: {filePath}/{pid}/{pid}.obj does not exist.') |
|
return False |
|
|
|
if not os.path.exists(f"{filePath}/{pid}/{pid}_preview.png"): |
|
print(f'{time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())}: {pid} Error: {filePath}/{pid}/{pid}.obj does not exist.') |
|
return False |
|
|
|
#清空oss上的文件 |
|
libs.clear_oss_by_pid(f'{ossPrefix}/{pid}') |
|
#上传文件到oss |
|
libs.upload_obj_to_oss(filePath,typeV,pid) |
|
return |
|
|
|
#程序主入口 |
|
if __name__ == '__main__': |
|
#atexit.register(common.notify,"处理数据校准任务已经停止") |
|
readTask() |
|
# while True: |
|
# pid = readTask() |