写一个简单案例测试能否将数据写入es
1 #!/usr/bin/env python 2 # -*- encoding: utf-8 -*- 3 # Created on 2017-10-27 08:35:57 4 # Project: es_test 5 6 from pyspider.libs.base_handler import * 7 from elasticsearch import Elasticsearch 8 9 class Handler(BaseHandler): 10 crawl_config = { 11 } 12 13 def __init__(self): 14 self.index = 1 15 16 @every(minutes=24 * 60) 17 def on_start(self): 18 es = Elasticsearch("ip") 19 for num in range(1,5): 20 es.index(index="my-index", doc_type="test-type",id=self.index, 21 body={ 22 "any": "data01" 23 }) 24 self.index += 1
es = Elasticsearch() 方法默认连接本地9200端口,需要本地安装es并启动;如果需要连接远程es数据库,可以这样
es = Elasticsearch("ip")
查看一下es中是否已有数据: