module.py 4.2 KB
Newer Older
D
dyning 已提交
1 2 3 4 5
# -*- coding:utf-8 -*-
from __future__ import absolute_import
from __future__ import division
from __future__ import print_function

littletomatodonkey's avatar
littletomatodonkey 已提交
6 7
import os
import sys
littletomatodonkey's avatar
littletomatodonkey 已提交
8
sys.path.insert(0, ".")
littletomatodonkey's avatar
littletomatodonkey 已提交
9

D
dyning 已提交
10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
import argparse
import ast
import copy
import math
import time

from paddle.fluid.core import AnalysisConfig, create_paddle_predictor, PaddleTensor
from paddlehub.common.logger import logger
from paddlehub.module.module import moduleinfo, runnable, serving
from PIL import Image
import cv2
import numpy as np
import paddle.fluid as fluid
import paddlehub as hub

D
dyning 已提交
25
from tools.infer.utility import base64_to_cv2
D
dyning 已提交
26 27 28 29 30 31 32 33 34 35 36
from tools.infer.predict_system import TextSystem


@moduleinfo(
    name="ocr_system",
    version="1.0.0",
    summary="ocr system service",
    author="paddle-dev",
    author_email="paddle-dev@baidu.com",
    type="cv/text_recognition")
class OCRSystem(hub.Module):
37
    def _initialize(self, use_gpu=False, enable_mkldnn=False):
D
dyning 已提交
38 39 40
        """
        initialize with the necessary elements
        """
D
dyning 已提交
41 42 43 44
        from ocr_system.params import read_params
        cfg = read_params()

        cfg.use_gpu = use_gpu
D
dyning 已提交
45 46 47 48 49 50
        if use_gpu:
            try:
                _places = os.environ["CUDA_VISIBLE_DEVICES"]
                int(_places[0])
                print("use gpu: ", use_gpu)
                print("CUDA_VISIBLE_DEVICES: ", _places)
D
dyning 已提交
51
                cfg.gpu_mem = 8000
D
dyning 已提交
52 53 54 55
            except:
                raise RuntimeError(
                    "Environment Variable CUDA_VISIBLE_DEVICES is not set correctly. If you wanna use gpu, please set CUDA_VISIBLE_DEVICES via export CUDA_VISIBLE_DEVICES=cuda_device_id."
                )
D
dyning 已提交
56
        cfg.ir_optim = True
57
        cfg.enable_mkldnn = enable_mkldnn
littletomatodonkey's avatar
littletomatodonkey 已提交
58

D
dyning 已提交
59
        self.text_sys = TextSystem(cfg)
D
dyning 已提交
60 61 62 63 64 65 66 67 68 69 70 71 72

    def read_images(self, paths=[]):
        images = []
        for img_path in paths:
            assert os.path.isfile(
                img_path), "The {} isn't a valid file.".format(img_path)
            img = cv2.imread(img_path)
            if img is None:
                logger.info("error in loading image:{}".format(img_path))
                continue
            images.append(img)
        return images

littletomatodonkey's avatar
littletomatodonkey 已提交
73
    def predict(self, images=[], paths=[]):
D
dyning 已提交
74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95
        """
        Get the chinese texts in the predicted images.
        Args:
            images (list(numpy.ndarray)): images data, shape of each is [H, W, C]. If images not paths
            paths (list[str]): The paths of images. If paths not images
        Returns:
            res (list): The result of chinese texts and save path of images.
        """

        if images != [] and isinstance(images, list) and paths == []:
            predicted_data = images
        elif images == [] and isinstance(paths, list) and paths != []:
            predicted_data = self.read_images(paths)
        else:
            raise TypeError("The input data is inconsistent with expectations.")

        assert predicted_data != [], "There is not any image to be predicted. Please check the input data."

        all_results = []
        for img in predicted_data:
            if img is None:
                logger.info("error in loading image")
D
dyning 已提交
96
                all_results.append([])
D
dyning 已提交
97 98
                continue
            starttime = time.time()
D
dyning 已提交
99
            dt_boxes, rec_res = self.text_sys(img)
D
dyning 已提交
100
            elapse = time.time() - starttime
D
dyning 已提交
101 102
            logger.info("Predict time: {}".format(elapse))

D
dyning 已提交
103 104
            dt_num = len(dt_boxes)
            rec_res_final = []
D
dyning 已提交
105

D
dyning 已提交
106 107
            for dno in range(dt_num):
                text, score = rec_res[dno]
littletomatodonkey's avatar
littletomatodonkey 已提交
108 109 110 111 112
                rec_res_final.append({
                    'text': text,
                    'confidence': float(score),
                    'text_region': dt_boxes[dno].astype(np.int).tolist()
                })
D
dyning 已提交
113
            all_results.append(rec_res_final)
D
dyning 已提交
114 115 116 117 118 119 120 121
        return all_results

    @serving
    def serving_method(self, images, **kwargs):
        """
        Run as a service.
        """
        images_decode = [base64_to_cv2(image) for image in images]
D
dyning 已提交
122
        results = self.predict(images_decode, **kwargs)
D
dyning 已提交
123 124
        return results

littletomatodonkey's avatar
littletomatodonkey 已提交
125

D
dyning 已提交
126 127 128 129 130 131
if __name__ == '__main__':
    ocr = OCRSystem()
    image_path = [
        './doc/imgs/11.jpg',
        './doc/imgs/12.jpg',
    ]
D
dyning 已提交
132
    res = ocr.predict(paths=image_path)
littletomatodonkey's avatar
littletomatodonkey 已提交
133
    print(res)