如何利用
bulk官方python客户端的方法？
import jsonfrom noaa_sdk import noaafrom elasticsearch import Elasticsearchfrom elasticsearch.helpers import bulknoaa_client = noaa.NOAA()alerts = noaa_client.alerts()['features']es = Elasticsearch()def save_alerts(): with open('nhc_alerts.json', 'w') as f: f.write(json.dumps(alerts))def bulk_sync(): actions = [ { "_index": "my_noaa_index", "_source": alert } for alert in alerts ] bulk(es, actions)save_alerts()bulk_sync()
