es工具

estool/Esmethod.py

@@ -18,7 +18,6 @@ class EsMethod(object):
         self.index_name='researchreportdata'
 
 
-
     '''
     模糊
     # 查询方法：模糊查询（会被分词）。
@@ -163,55 +162,22 @@ class EsMethod(object):
             'query': {
                 'bool': {
                     'should':[
-                        {'term':{'labels.relationId' : '91110108740053589U'}},
-                        {'term':{'type' : 3}},
+                        # {'term':{'origin' : '雪球网'}},
+                        {'term':{'type' : 1}},
                     ],
-                    # 'must': [
-                    #     {'match': {'title': '.pdf'}}
-                    # ]
-                }
-            },
-            'from' : pnum,
-            'size' : 600,
-        }
-        body = {
-            "query": {
-                "bool": {
-                    "must": [
-                        {
-                            "nested": {
-                                "path": "labels",
-                                "query": {
-                                    "match": {
-                                        "labels.relationId": "91110108740053589U"
-                                    }
-                                }
-                            }
-                        },
-                        {
-                            "term": {
-                                "type.keyword": {
-                                    "value": "3"
-                                }
-                            }
-                        }
+                    'must': [
+                        {'match': {'title': '.pdf'}}
                     ]
                 }
             },
-            "sort": [
-                {
-                    "publishDate": {
-                        "order": "desc"
-                    }
-                }
-            ],
-            "track_total_hits": True,
-            "size": 212
+            'from' : pnum,
+            'size' : 6000,
         }
 
         filter_path=['hits.hits._source.title',  # 字段1
                      'hits.hits._source.id',
                      'hits.total.value',
+                     'hits.hits._source.type',
                      ]   # 字段2
         result = self.es.search(index=index_name
                                 ,doc_type='_doc'
@@ -240,6 +206,8 @@ class EsMethod(object):
         print(fields)
 
 
+
+
 if __name__ == '__main__':
     esMethod=EsMethod()
     # esMethod.getFileds(index_name=esMethod.index_name)
@@ -255,8 +223,8 @@ if __name__ == '__main__':
             title=mms['_source']['title']
             utitle=title.replace('.pdf','')
             print(f'id:{id}---title:{title}--utitle:{utitle}')
-            # esMethod.updateaunn(esMethod.index_name,str(id),utitle)
-            esMethod.delete(esMethod.index_name,str(id))
+            esMethod.updateaunn(esMethod.index_name,str(id),utitle)
+            # esMethod.delete(esMethod.index_name,str(id))
             print('跟新成功！！')