如何使用python检查来自API的数据是否在elasticsearch索引中，如果不是，则插入它

Question

我想从 Open Weather Map API 中检索一些数据，并使用 Python 将它们插入到 Elasticsearch 索引中。然后我会拿一些新的并检查它们是否已经在索引中。如果不是，我会将它们添加到索引中。如果它们已经在其中，则应忽略它们。

import datetime

from pprint import pprint

import requests

import urllib

import json

import request

from elasticsearch import Elasticsearch

from elasticsearch import helpers

import time

es = Elasticsearch([{'host': 'localhost', 'port': 9200}])

r = requests.get('http://api.openweathermap.org/data/2.5/weather?q=London&appid=###').json()

pprint(r)

res = es.search(index="weathermap", body={"query": {"match_all": {}}})

for m in res:

   if m not in res:

      es.index(index='weathermap', doc_type='doc')