MOD
Showing
1 changed file
with
3 additions
and
1 deletions
... | @@ -1653,6 +1653,7 @@ class Command(BaseCommand, LoggerMixin): | ... | @@ -1653,6 +1653,7 @@ class Command(BaseCommand, LoggerMixin): |
1653 | '[error={4}]'.format(self.log_base, times, url, img_path, | 1653 | '[error={4}]'.format(self.log_base, times, url, img_path, |
1654 | traceback.format_exc())) | 1654 | traceback.format_exc())) |
1655 | else: | 1655 | else: |
1656 | self.online_log.info('{0} [ocr_1 start] [img={1}] [url={2}]'.format(self.log_base, img_path, url)) | ||
1656 | ocr_1_res = ocr_1_response.json() | 1657 | ocr_1_res = ocr_1_response.json() |
1657 | end_time = time.time() | 1658 | end_time = time.time() |
1658 | speed_time = int(end_time - start_time) | 1659 | speed_time = int(end_time - start_time) |
... | @@ -1699,8 +1700,9 @@ class Command(BaseCommand, LoggerMixin): | ... | @@ -1699,8 +1700,9 @@ class Command(BaseCommand, LoggerMixin): |
1699 | self.online_log.info('{0} [res_2_wb] [get task] [queue running] [finish_queue_size={1}]'.format(self.log_base, finish_queue.qsize())) | 1700 | self.online_log.info('{0} [res_2_wb] [get task] [queue running] [finish_queue_size={1}]'.format(self.log_base, finish_queue.qsize())) |
1700 | while len(error_list) == 0 or not img_queue.empty() or not finish_queue.empty(): | 1701 | while len(error_list) == 0 or not img_queue.empty() or not finish_queue.empty(): |
1701 | try: | 1702 | try: |
1703 | self.online_log.info('{0} [res_2_wb] [finish_queue.get1] [finish_queue_size={1}] [img_queue_size={2}]'.format(self.log_base, finish_queue.qsize(), img_queue.qsize())) | ||
1702 | task_str = finish_queue.get(block=False) | 1704 | task_str = finish_queue.get(block=False) |
1703 | self.online_log.info('{0} [res_2_wb] [finish_queue.get]'.format(self.log_base)) | 1705 | self.online_log.info('{0} [res_2_wb] [finish_queue.get2]'.format(self.log_base)) |
1704 | except Exception as e: | 1706 | except Exception as e: |
1705 | self.online_log.info('{0} [res_2_wb] [queue empty]'.format(self.log_base)) | 1707 | self.online_log.info('{0} [res_2_wb] [queue empty]'.format(self.log_base)) |
1706 | time.sleep(self.sleep_time_task_get) | 1708 | time.sleep(self.sleep_time_task_get) | ... | ... |
-
Please register or sign in to post a comment