|
|
@@ -1,6 +1,6 @@
|
|
|
import re
|
|
|
|
|
|
-from utils.es_query import get_es
|
|
|
+from utils.databases import es_query
|
|
|
from utils.execptions import (
|
|
|
CustomAccountPrivilegeError,
|
|
|
CustomCheckError
|
|
|
@@ -77,7 +77,7 @@ class CheckPrePareRequest:
|
|
|
:param publish_time: 发布时间的时间戳(l_np_publishtime)
|
|
|
:param rows: 采集内容
|
|
|
"""
|
|
|
- retrieved_result = get_es(title, publish_time)
|
|
|
+ retrieved_result = es_query(title, publish_time)
|
|
|
if retrieved_result != 0:
|
|
|
'''es查询数据结果'''
|
|
|
rows['count'] = retrieved_result
|
dongzhaorui@topnet.net.cn