modelFactory.py 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629
  1. '''
  2. Created on 2019年5月16日
  3. @author: User
  4. '''
  5. import os
  6. import sys
  7. sys.path.append(os.path.abspath("../.."))
  8. from keras import models
  9. from keras import layers
  10. # from keras_contrib.layers import CRF
  11. from keras.preprocessing.sequence import pad_sequences
  12. from keras import optimizers,losses,metrics
  13. from BiddingKG.dl.common.Utils import *
  14. import tensorflow as tf
  15. import json
  16. class Model_role_classify():
  17. def __init__(self,lazyLoad=getLazyLoad()):
  18. #self.model_role_file = os.path.abspath("../role/models/model_role.model.hdf5")
  19. self.model_role_file = os.path.dirname(__file__)+"/../role/log/new_biLSTM-ep012-loss0.028-val_loss0.040-f10.954.h5"
  20. self.model_role = None
  21. self.graph = tf.get_default_graph()
  22. if not lazyLoad:
  23. self.getModel()
  24. def getModel(self):
  25. if self.model_role is None:
  26. self.model_role = models.load_model(self.model_role_file,custom_objects={'precision':precision,'recall':recall,'f1_score':f1_score})
  27. return self.model_role
  28. def encode(self,tokens,begin_index,end_index,**kwargs):
  29. return embedding(spanWindow(tokens=tokens,begin_index=begin_index,end_index=end_index,size=10),shape=(2,10,128))
  30. def predict(self,x):
  31. x = np.transpose(np.array(x),(1,0,2,3))
  32. with self.graph.as_default():
  33. return self.getModel().predict([x[0],x[1]])
  34. class Model_role_classify_word():
  35. def __init__(self,lazyLoad=getLazyLoad(),config=None):
  36. if USE_PAI_EAS:
  37. lazyLoad = True
  38. #self.model_role_file = os.path.abspath("../role/log/ep071-loss0.107-val_loss0.122-f10.956.h5")
  39. # self.model_role_file = os.path.dirname(__file__)+"/../role/models/ep038-loss0.140-val_loss0.149-f10.947.h5"
  40. #self.model_role_file = os.path.abspath("../role/log/textcnn_ep017-loss0.088-val_loss0.125-f10.955.h5")
  41. self.model_role = None
  42. self.sess_role = tf.Session(graph=tf.Graph(),config=config)
  43. if not lazyLoad:
  44. self.getModel()
  45. def getModel(self):
  46. if self.model_role is None:
  47. with self.sess_role.as_default() as sess:
  48. with self.sess_role.graph.as_default():
  49. meta_graph_def = tf.saved_model.loader.load(sess=self.sess_role, tags=["serve"], export_dir=os.path.dirname(__file__)+"/role_savedmodel")
  50. signature_key = tf.saved_model.signature_constants.DEFAULT_SERVING_SIGNATURE_DEF_KEY
  51. signature_def = meta_graph_def.signature_def
  52. input0 = self.sess_role.graph.get_tensor_by_name(signature_def[signature_key].inputs["input0"].name)
  53. input1 = self.sess_role.graph.get_tensor_by_name(signature_def[signature_key].inputs["input1"].name)
  54. # input2 = self.sess_role.graph.get_tensor_by_name(signature_def[signature_key].inputs["input2"].name)
  55. output = self.sess_role.graph.get_tensor_by_name(signature_def[signature_key].outputs["outputs"].name)
  56. self.model_role = [[input0,input1],output] #,input2
  57. return self.model_role
  58. '''
  59. def load_weights(self):
  60. model = self.getModel()
  61. model.load_weights(self.model_role_file)
  62. '''
  63. def encode(self,tokens,begin_index,end_index,entity_text,**kwargs):
  64. _span = spanWindow(tokens=tokens,begin_index=begin_index,end_index=end_index,size=20,center_include=False,word_flag=True,text=entity_text) #size=12 center_include=True
  65. # print(_span)
  66. _encode_span = encodeInput(_span, word_len=20, word_flag=True,userFool=False) # word_len=20
  67. # print(_encode_span)
  68. return _encode_span
  69. def fix_digit_eng(self, text):
  70. '''
  71. 处理数字及英文编号等
  72. :param text:
  73. :return:
  74. '''
  75. text = re.sub('第[一二三1-3]([条项章]|中学|医院|附属)|第三方(服务机构)?', 'xxx', text)
  76. text = re.sub('第01(中标|成交)?候选人', '第一中标候选人', text)
  77. text = re.sub('标段[一二三1-3]', '标段d', text)
  78. text = re.sub('第[一二三1-3](标段?|[分子标]?包)', 'd标段', text)
  79. text = re.sub('[a-zA-Z][a-zA-Z0-9=&_—-]{3,}', 'abc', text)
  80. text = re.sub('[【(\[][0-9]{2,}[\])】]|\d+([::.-]\d+)+', 'd', text)
  81. text = re.sub('[一二三四五六七八九十]{2,}|[四五六七八九十]+', 'd', text)
  82. text = re.sub('\d{2,}(\.\d+)?|\d\.\d+|[04-9]', 'd', text)
  83. text = re.sub('序号:\d+|第?[一二三四五六七八九十\d]+次|[一二三四五六七八九十\d]+、', '', text)
  84. return text.replace('(', '(').replace(')', ')')
  85. def encode_word(self, sentence_text, begin_index, end_index, size=20, **kwargs):
  86. '''
  87. 上下文数字化,使用字偏移
  88. :param sentence_text: 句子文本
  89. :param begin_index: 实体字开始位置
  90. :param end_index: 实体字结束位置
  91. :param size: 字偏移量
  92. :param kwargs:
  93. :return:
  94. '''
  95. _span = get_context(sentence_text, begin_index, end_index,size=size, center_include=False) # size=12 center_include=True
  96. # print(_span)
  97. _span = [self.fix_digit_eng(text) for text in _span]
  98. _encode_span = encodeInput(_span, word_len=30, word_flag=True, userFool=False) # word_len=20
  99. # print(_encode_span)
  100. return _encode_span
  101. def predict(self,x):
  102. x = np.transpose(np.array(x),(1,0,2))
  103. model_role = self.getModel()
  104. assert len(x)==len(model_role[0])
  105. feed_dict = {}
  106. for _x,_t in zip(x,model_role[0]):
  107. feed_dict[_t] = _x
  108. list_result = limitRun(self.sess_role,[model_role[1]],feed_dict)[0]
  109. return list_result
  110. #return self.sess_role.run(model_role[1],feed_dict=feed_dict)
  111. class Model_money_classify():
  112. def __init__(self,lazyLoad=getLazyLoad(),config=None):
  113. if USE_PAI_EAS:
  114. lazyLoad = True
  115. self.model_money_file = os.path.dirname(__file__)+"/../money/models/model_money_word.h5"
  116. self.model_money = None
  117. self.sess_money = tf.Session(graph=tf.Graph(),config=config)
  118. if not lazyLoad:
  119. self.getModel()
  120. def getModel(self):
  121. if self.model_money is None:
  122. with self.sess_money.as_default() as sess:
  123. with sess.graph.as_default():
  124. meta_graph_def = tf.saved_model.loader.load(sess,tags=["serve"],export_dir=os.path.dirname(__file__)+"/money_savedmodel")
  125. # meta_graph_def = tf.saved_model.loader.load(sess,tags=["serve"],export_dir=os.path.dirname(__file__)+"/money_savedmodel_bilstmonly")
  126. signature_key = tf.saved_model.signature_constants.DEFAULT_SERVING_SIGNATURE_DEF_KEY
  127. signature_def = meta_graph_def.signature_def
  128. input0 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input0"].name)
  129. input1 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input1"].name)
  130. input2 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input2"].name)
  131. output = sess.graph.get_tensor_by_name(signature_def[signature_key].outputs["outputs"].name)
  132. self.model_money = [[input0,input1,input2],output]
  133. return self.model_money
  134. '''
  135. if self.model_money is None:
  136. self.model_money = models.load_model(self.model_money_file,custom_objects={'precision':precision,'recall':recall,'f1_score':f1_score})
  137. return self.model_money
  138. '''
  139. '''
  140. def load_weights(self):
  141. model = self.getModel()
  142. model.load_weights(self.model_money_file)
  143. '''
  144. def encode(self,tokens,begin_index,end_index,**kwargs):
  145. _span = spanWindow(tokens=tokens, begin_index=begin_index, end_index=end_index, size=10, center_include=True, word_flag=True)
  146. # print(_span)
  147. return encodeInput(_span, word_len=30, word_flag=True,userFool=False)
  148. return embedding_word(_span,shape=(3,100,60))
  149. def predict(self,x):
  150. # print("shape",np.shape(x))
  151. x = np.transpose(np.array(x),(1,0,2))
  152. model_money = self.getModel()
  153. assert len(x)==len(model_money[0])
  154. feed_dict = {}
  155. for _x,_t in zip(x,model_money[0]):
  156. feed_dict[_t] = _x
  157. list_result = limitRun(self.sess_money,[model_money[1]],feed_dict)[0]
  158. #return self.sess_money.run(model_money[1],feed_dict=feed_dict)
  159. return list_result
  160. '''
  161. with self.graph.as_default():
  162. return self.getModel().predict([x[0],x[1],x[2]])
  163. '''
  164. from itertools import groupby
  165. from BiddingKG.dl.relation_extraction.model import get_words_matrix
  166. class Model_relation_extraction():
  167. def __init__(self,lazyLoad=getLazyLoad()):
  168. if USE_PAI_EAS:
  169. lazyLoad = True
  170. self.subject_model_file = os.path.dirname(__file__)+"/../relation_extraction/models2/subject_model"
  171. self.object_model_file = os.path.dirname(__file__)+"/../relation_extraction/models2/object_model"
  172. self.model_subject = None
  173. self.model_object = None
  174. self.sess_subject = tf.Session(graph=tf.Graph())
  175. self.sess_object = tf.Session(graph=tf.Graph())
  176. if not lazyLoad:
  177. self.getModel1()
  178. self.getModel2()
  179. self.entity_type_dict = {
  180. 'org': '<company/org>',
  181. 'company': '<company/org>',
  182. 'location': '<location>',
  183. 'phone': '<phone>',
  184. 'person': '<contact_person>'
  185. }
  186. self.id2predicate = {
  187. 0: "rel_person", # 公司——联系人
  188. 1: "rel_phone", # 联系人——电话
  189. 2: "rel_address" # 公司——地址
  190. }
  191. self.words_size = 128
  192. # subject_model
  193. def getModel1(self):
  194. if self.model_subject is None:
  195. with self.sess_subject.as_default() as sess:
  196. with sess.graph.as_default():
  197. meta_graph_def = tf.saved_model.loader.load(sess,tags=["serve"],export_dir=self.subject_model_file)
  198. signature_key = tf.saved_model.signature_constants.DEFAULT_SERVING_SIGNATURE_DEF_KEY
  199. signature_def = meta_graph_def.signature_def
  200. input0 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input0"].name)
  201. input1 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input1"].name)
  202. output = sess.graph.get_tensor_by_name(signature_def[signature_key].outputs["outputs"].name)
  203. self.model_subject = [[input0,input1],output]
  204. return self.model_subject
  205. # object_model
  206. def getModel2(self):
  207. if self.model_object is None:
  208. with self.sess_object.as_default() as sess:
  209. with sess.graph.as_default():
  210. meta_graph_def = tf.saved_model.loader.load(sess,tags=["serve"],export_dir=self.object_model_file)
  211. signature_key = tf.saved_model.signature_constants.DEFAULT_SERVING_SIGNATURE_DEF_KEY
  212. signature_def = meta_graph_def.signature_def
  213. input0 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input0"].name)
  214. input1 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input1"].name)
  215. input2 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input2"].name)
  216. output = sess.graph.get_tensor_by_name(signature_def[signature_key].outputs["outputs"].name)
  217. self.model_object = [[input0,input1,input2],output]
  218. return self.model_object
  219. def encode(self,entity_list,list_sentence):
  220. list_sentence = sorted(list_sentence, key=lambda x: x.sentence_index)
  221. entity_list = sorted(entity_list, key=lambda x: (x.sentence_index, x.begin_index))
  222. pre_data = []
  223. text_data = []
  224. last_sentence_index = -1
  225. for key, group in groupby(entity_list, key=lambda x: x.sentence_index):
  226. if key - last_sentence_index > 1:
  227. for i in range(last_sentence_index + 1, key):
  228. pre_data.extend(list_sentence[i].tokens)
  229. text_data.extend([0] * len(list_sentence[i].tokens))
  230. group = list(group)
  231. for i in range(len(group)):
  232. ent = group[i]
  233. _tokens = list_sentence[key].tokens
  234. if i == len(group) - 1:
  235. if i == 0:
  236. pre_data.extend(_tokens[:ent.begin_index])
  237. text_data.extend([0] * len(_tokens[:ent.begin_index]))
  238. pre_data.append(self.entity_type_dict[ent.entity_type])
  239. text_data.append(ent)
  240. pre_data.extend(_tokens[ent.end_index + 1:])
  241. text_data.extend([0] * len(_tokens[ent.end_index + 1:]))
  242. break
  243. else:
  244. pre_data.append(self.entity_type_dict[ent.entity_type])
  245. text_data.append(ent)
  246. pre_data.extend(_tokens[ent.end_index + 1:])
  247. text_data.extend([0] * len(_tokens[ent.end_index + 1:]))
  248. break
  249. if i == 0:
  250. pre_data.extend(_tokens[:ent.begin_index])
  251. text_data.extend([0] * len(_tokens[:ent.begin_index]))
  252. pre_data.append(self.entity_type_dict[ent.entity_type])
  253. text_data.append(ent)
  254. pre_data.extend(_tokens[ent.end_index + 1:group[i + 1].begin_index])
  255. text_data.extend([0] * len(_tokens[ent.end_index + 1:group[i + 1].begin_index]))
  256. else:
  257. pre_data.append(self.entity_type_dict[ent.entity_type])
  258. text_data.append(ent)
  259. pre_data.extend(_tokens[ent.end_index + 1:group[i + 1].begin_index])
  260. text_data.extend([0] * len(_tokens[ent.end_index + 1:group[i + 1].begin_index]))
  261. last_sentence_index = key
  262. return text_data, pre_data
  263. def check_data(self, words):
  264. # 检查数据是否包含可预测的subject和object
  265. # 没有需要预测的链接属性,直接return
  266. company_relation = 0
  267. person_relation = 0
  268. if '<company/org>' in words:
  269. company_relation += 1
  270. if '<contact_person>' in words:
  271. person_relation += 1
  272. if company_relation:
  273. company_relation += 1
  274. # 暂时不考虑地址location实体
  275. # if '<location>' in words and company_relation:
  276. # company_relation += 1
  277. if '<phone>' in words and company_relation:
  278. person_relation += 1
  279. if company_relation < 2 and person_relation < 2:
  280. return False
  281. return True
  282. def predict_by_api(self,text_in,words,sentence_vetor):
  283. status_code = 0
  284. # save([words,sentence_vetor.tolist()],"C:/Users/Administrator/Desktop/test_data.pk")
  285. try:
  286. requests_result = requests.post(API_URL + "/predict_relation", json={"sentence_vetor": sentence_vetor.tolist(), "words": words},
  287. verify=True)
  288. status_code = requests_result.status_code
  289. triple_index_list = json.loads(requests_result.text)['triple_list']
  290. # print("triple_list:",json.loads(requests_result.text)['triple_list'])
  291. print("cost_time:",json.loads(requests_result.text)['cost_time'])
  292. triple_list = [(text_in[triple[0]], triple[1], text_in[triple[2]]) for triple in triple_index_list]
  293. return triple_list,status_code
  294. except Exception as e:
  295. print(e)
  296. return [],status_code
  297. def predict(self,text_in, words, rate=0.5):
  298. _t2 = np.zeros((len(words), self.words_size))
  299. for i in range(len(words)):
  300. _t2[i] = np.array(get_words_matrix(words[i]))
  301. # a = time.time()
  302. # triple_list, status_code = self.predict_by_api(text_in, words,_t2)
  303. # print('time',time.time()-a)
  304. # print("status_code",status_code)
  305. # if status_code==200:
  306. # return triple_list
  307. # else:
  308. # 使用模型预测
  309. triple_list = []
  310. # print("tokens:",words)
  311. # _t2 = [self.words2id.get(c, 1) for c in words]
  312. _t2 = np.array([_t2])
  313. _t3 = [1 for _ in words]
  314. _t3 = np.array([_t3])
  315. # _k1 = self.model_subject.predict([_t2, _t3])
  316. _k1 = limitRun(self.sess_subject,[self.model_subject[1]],feed_dict={self.model_subject[0][0]:_t2,
  317. self.model_subject[0][1]:_t3})[0]
  318. _k1 = _k1[0, :, 0]
  319. _k1 = np.where(_k1 > rate)[0]
  320. # print('k1',_k1)
  321. _subjects = []
  322. for i in _k1:
  323. _subject = text_in[i]
  324. _subjects.append((_subject, i, i))
  325. if _subjects:
  326. _t2 = np.repeat(_t2, len(_subjects), 0)
  327. _t3 = np.repeat(_t3, len(_subjects), 0)
  328. _k1, _ = np.array([_s[1:] for _s in _subjects]).T.reshape((2, -1, 1))
  329. # _o1 = self.model_object.predict([_t2, _t3, _k1])
  330. _o1 = limitRun(self.sess_object, [self.model_object[1]], feed_dict={self.model_object[0][0]: _t2,
  331. self.model_object[0][1]: _t3,
  332. self.model_object[0][2]: _k1})[0]
  333. for i, _subject in enumerate(_subjects):
  334. _oo1 = np.where(_o1[i] > 0.5)
  335. # print('_oo1', _oo1)
  336. for _ooo1, _c1 in zip(*_oo1):
  337. _object = text_in[_ooo1]
  338. _predicate = self.id2predicate[_c1]
  339. triple_list.append((_subject[0], _predicate, _object))
  340. # print([(t[0].entity_text,t[1],t[2].entity_text) for t in triple_list])
  341. return triple_list
  342. else:
  343. return []
  344. class Model_person_classify():
  345. def __init__(self,lazyLoad=getLazyLoad(),config=None):
  346. if USE_PAI_EAS:
  347. lazyLoad = True
  348. self.model_person_file = os.path.dirname(__file__)+"/../person/models/model_person.model.hdf5"
  349. self.model_person = None
  350. self.sess_person = tf.Session(graph=tf.Graph(),config=config)
  351. if not lazyLoad:
  352. self.getModel()
  353. def getModel(self):
  354. if self.model_person is None:
  355. with self.sess_person.as_default() as sess:
  356. with sess.graph.as_default():
  357. # meta_graph_def = tf.saved_model.loader.load(sess,tags=["serve"],export_dir=os.path.dirname(__file__)+"/person_savedmodel_new")
  358. meta_graph_def = tf.saved_model.loader.load(sess,tags=["serve"],export_dir=os.path.dirname(__file__)+"/person_savedmodel_new_znj")
  359. signature_key = tf.saved_model.signature_constants.DEFAULT_SERVING_SIGNATURE_DEF_KEY
  360. signature_def = meta_graph_def.signature_def
  361. input0 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input0"].name)
  362. input1 = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["input1"].name)
  363. output = sess.graph.get_tensor_by_name(signature_def[signature_key].outputs["outputs"].name)
  364. self.model_person = [[input0,input1],output]
  365. return self.model_person
  366. '''
  367. if self.model_person is None:
  368. self.model_person = models.load_model(self.model_person_file,custom_objects={'precision':precision,'recall':recall,'f1_score':f1_score})
  369. return self.model_person
  370. '''
  371. '''
  372. def load_weights(self):
  373. model = self.getModel()
  374. model.load_weights(self.model_person_file)
  375. '''
  376. def encode(self,tokens,begin_index,end_index,**kwargs):
  377. # return embedding(spanWindow(tokens=tokens,begin_index=begin_index,end_index=end_index,size=10),shape=(2,10,128))
  378. return embedding(spanWindow(tokens=tokens,begin_index=begin_index,end_index=end_index,size=20),shape=(2,20,128))
  379. def predict(self,x):
  380. x = np.transpose(np.array(x),(1,0,2,3))
  381. model_person = self.getModel()
  382. assert len(x)==len(model_person[0])
  383. feed_dict = {}
  384. for _x,_t in zip(x,model_person[0]):
  385. feed_dict[_t] = _x
  386. list_result = limitRun(self.sess_person,[model_person[1]],feed_dict)[0]
  387. return list_result
  388. #return self.sess_person.run(model_person[1],feed_dict=feed_dict)
  389. '''
  390. with self.graph.as_default():
  391. return self.getModel().predict([x[0],x[1]])
  392. '''
  393. class Model_form_line():
  394. def __init__(self,lazyLoad=getLazyLoad()):
  395. self.model_file = os.path.dirname(__file__)+"/../form/model/model_form.model - 副本.hdf5"
  396. self.model_form = None
  397. self.graph = tf.get_default_graph()
  398. if not lazyLoad:
  399. self.getModel()
  400. def getModel(self):
  401. if self.model_form is None:
  402. self.model_form = models.load_model(self.model_file,custom_objects={"precision":precision,"recall":recall,"f1_score":f1_score})
  403. return self.model_form
  404. def encode(self,data,shape=(100,60),expand=False,**kwargs):
  405. embedding = np.zeros(shape)
  406. word_model = getModel_word()
  407. for i in range(len(data)):
  408. if i>=shape[0]:
  409. break
  410. if data[i] in word_model.vocab:
  411. embedding[i] = word_model[data[i]]
  412. if expand:
  413. embedding = np.expand_dims(embedding,0)
  414. return embedding
  415. def predict(self,x):
  416. with self.graph.as_default():
  417. return self.getModel().predict(x)
  418. class Model_form_item():
  419. def __init__(self,lazyLoad=getLazyLoad(),config=None):
  420. self.model_file = os.path.dirname(__file__)+"/../form/log/ep039-loss0.038-val_loss0.064-f10.9783.h5"
  421. self.model_form = None
  422. self.sess_form = tf.Session(graph=tf.Graph(),config=config)
  423. if not lazyLoad:
  424. self.getModel()
  425. def getModel(self):
  426. if self.model_form is None:
  427. with self.sess_form.as_default() as sess:
  428. with sess.graph.as_default():
  429. meta_graph_def = tf.saved_model.loader.load(sess,tags=["serve"],export_dir="%s/form_savedmodel"%(os.path.dirname(__file__)))
  430. signature_key = tf.saved_model.signature_constants.DEFAULT_SERVING_SIGNATURE_DEF_KEY
  431. signature_def = meta_graph_def.signature_def
  432. inputs = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["inputs"].name)
  433. output = sess.graph.get_tensor_by_name(signature_def[signature_key].outputs["outputs"].name)
  434. self.model_form = [[inputs],output]
  435. return self.model_form
  436. '''
  437. if self.model_form is None:
  438. with self.graph.as_defalt():
  439. self.model_form = models.load_model(self.model_file,custom_objects={"precision":precision,"recall":recall,"f1_score":f1_score})
  440. return self.model_form
  441. '''
  442. def encode(self,data,**kwargs):
  443. return encodeInput([data], word_len=50, word_flag=True,userFool=False)[0]
  444. return encodeInput_form(data)
  445. def predict(self,x):
  446. if USE_API:
  447. requests_result = requests.post(API_URL+"/predict_form_item",json={"inputs":x.tolist()}, verify=True)
  448. list_result = json.loads(requests_result.text)['result']
  449. else:
  450. model_form = self.getModel()
  451. list_result = limitRun(self.sess_form,[model_form[1]],feed_dict={model_form[0][0]:x})[0]
  452. return list_result
  453. # return self.sess_form.run(model_form[1],feed_dict={model_form[0][0]:x})
  454. '''
  455. with self.graph.as_default():
  456. return self.getModel().predict(x)
  457. '''
  458. class Model_form_context():
  459. def __init__(self,lazyLoad=getLazyLoad(),config=None):
  460. self.model_form = None
  461. self.sess_form = tf.Session(graph=tf.Graph(),config=config)
  462. if not lazyLoad:
  463. self.getModel()
  464. def getModel(self):
  465. if self.model_form is None:
  466. with self.sess_form.as_default() as sess:
  467. with sess.graph.as_default():
  468. meta_graph_def = tf.saved_model.loader.load(sess,tags=["serve"],export_dir="%s/form_context_savedmodel"%(os.path.dirname(__file__)))
  469. signature_key = tf.saved_model.signature_constants.DEFAULT_SERVING_SIGNATURE_DEF_KEY
  470. signature_def = meta_graph_def.signature_def
  471. inputs = sess.graph.get_tensor_by_name(signature_def[signature_key].inputs["inputs"].name)
  472. output = sess.graph.get_tensor_by_name(signature_def[signature_key].outputs["outputs"].name)
  473. self.model_form = [[inputs],output]
  474. return self.model_form
  475. '''
  476. if self.model_form is None:
  477. with self.graph.as_defalt():
  478. self.model_form = models.load_model(self.model_file,custom_objects={"precision":precision,"recall":recall,"f1_score":f1_score})
  479. return self.model_form
  480. '''
  481. def encode_table(self,inner_table,size=30):
  482. def encode_item(_table,i,j):
  483. _x = [_table[j-1][i-1],_table[j-1][i],_table[j-1][i+1],
  484. _table[j][i-1],_table[j][i],_table[j][i+1],
  485. _table[j+1][i-1],_table[j+1][i],_table[j+1][i+1]]
  486. e_x = [encodeInput_form(_temp[0],MAX_LEN=30) for _temp in _x]
  487. _label = _table[j][i][1]
  488. # print(_x)
  489. # print(_x[4],_label)
  490. return e_x,_label,_x
  491. def copytable(inner_table):
  492. table = []
  493. for line in inner_table:
  494. list_line = []
  495. for item in line:
  496. list_line.append([item[0][:size],item[1]])
  497. table.append(list_line)
  498. return table
  499. table = copytable(inner_table)
  500. padding = ["#"*30,0]
  501. width = len(table[0])
  502. height = len(table)
  503. table.insert(0,[padding for i in range(width)])
  504. table.append([padding for i in range(width)])
  505. for item in table:
  506. item.insert(0,padding.copy())
  507. item.append(padding.copy())
  508. data_x = []
  509. data_y = []
  510. data_text = []
  511. data_position = []
  512. for _i in range(1,width+1):
  513. for _j in range(1,height+1):
  514. _x,_y,_text = encode_item(table,_i,_j)
  515. data_x.append(_x)
  516. _label = [0,0]
  517. _label[_y] = 1
  518. data_y.append(_label)
  519. data_text.append(_text)
  520. data_position.append([_i-1,_j-1])
  521. # input = table[_j][_i][0]
  522. # item_y = [0,0]
  523. # item_y[table[_j][_i][1]] = 1
  524. # data_x.append(encodeInput([input], word_len=50, word_flag=True,userFool=False)[0])
  525. # data_y.append(item_y)
  526. return data_x,data_y,data_text,data_position
  527. def encode(self,inner_table,**kwargs):
  528. data_x,_,_,data_position = self.encode_table(inner_table)
  529. return data_x,data_position
  530. def predict(self,x):
  531. model_form = self.getModel()
  532. list_result = limitRun(self.sess_form,[model_form[1]],feed_dict={model_form[0][0]:x})[0]
  533. return list_result
  534. # class Model_form_item():
  535. # def __init__(self,lazyLoad=False):
  536. # self.model_file = os.path.dirname(__file__)+"/ep039-loss0.038-val_loss0.064-f10.9783.h5"
  537. # self.model_form = None
  538. #
  539. # if not lazyLoad:
  540. # self.getModel()
  541. # self.graph = tf.get_default_graph()
  542. #
  543. # def getModel(self):
  544. # if self.model_form is None:
  545. # self.model_form = models.load_model(self.model_file,custom_objects={"precision":precision,"recall":recall,"f1_score":f1_score})
  546. # return self.model_form
  547. #
  548. # def encode(self,data,**kwargs):
  549. #
  550. # return encodeInput_form(data)
  551. #
  552. # def predict(self,x):
  553. # with self.graph.as_default():
  554. # return self.getModel().predict(x)