module.py 4.1 KB
Newer Older
D
dyning 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33
# -*- coding:utf-8 -*-
from __future__ import absolute_import
from __future__ import division
from __future__ import print_function

import argparse
import ast
import copy
import math
import os
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

from tools.infer.utility import base64_to_cv2
from tools.infer.predict_rec import TextRecognizer


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

        cfg.use_gpu = use_gpu
D
dyning 已提交
42 43 44 45 46 47
        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 已提交
48
                cfg.gpu_mem = 8000
D
dyning 已提交
49 50 51 52
            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 已提交
53
        cfg.ir_optim = True
54
        cfg.enable_mkldnn = enable_mkldnn
D
dyning 已提交
55

D
dyning 已提交
56
        self.text_recognizer = TextRecognizer(cfg)
D
dyning 已提交
57 58 59 60 61 62 63 64 65 66 67 68 69

    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

D
dyning 已提交
70
    def predict(self,
D
dyning 已提交
71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95
                images=[],
                paths=[]):
        """
        Get the text box 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 text detection box 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."
        
        img_list = []
        for img in predicted_data:
            if img is None:
                continue
            img_list.append(img)
D
dyning 已提交
96 97
            
        rec_res_final = []
D
dyning 已提交
98
        try:
D
dyning 已提交
99
            rec_res, predict_time = self.text_recognizer(img_list)
D
dyning 已提交
100 101 102 103 104 105 106 107
            for dno in range(len(rec_res)):
                text, score = rec_res[dno]
                rec_res_final.append(
                    {
                        'text': text,
                        'confidence': float(score),
                    }
                )
D
dyning 已提交
108 109
        except Exception as e:
            print(e)
D
dyning 已提交
110 111 112 113
            return [[]]

        return [rec_res_final]

D
dyning 已提交
114 115 116 117 118 119 120

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

   
if __name__ == '__main__':
    ocr = OCRRec()
    image_path = [
        './doc/imgs_words/ch/word_1.jpg',
        './doc/imgs_words/ch/word_2.jpg',
        './doc/imgs_words/ch/word_3.jpg',
    ]
D
dyning 已提交
132
    res = ocr.predict(paths=image_path)
D
dyning 已提交
133
    print(res)