ElasticSearch实践

参考

• https://www.elastic.co/downloads/elasticsearch

安装

安装环境：ubuntu 15

###jre安装

运行 ElasticSearch 需要Java环境，因此需要安装 jre ：

sudo apt-get install openjdk-7-jre

ElasticSearch安装

从 参考 下载 ElasticSearch ，官方提供的 Installation Steps 说明很简单，只有三步：

1. 解压
2. 运行
3. 使用

解压 ElasticSearch：

sudo tar -zxvf elasticsearch-1.6.0.tar.gz -C /opt

进入目录并运行 ElasticSearch：

cd /opt/elasticsearch-1.6.0
sudo bin/elasticsearch

测试

使用浏览器访问 http://YourServerIP:9200/ 返回：

{
  "status" : 200,
  "name" : "Blistik",
  "cluster_name" : "elasticsearch",
  "version" : {
    "number" : "1.6.0",
    "build_hash" : "cdd3ac4dde4f69524ec0a14de3828cb95bbb86d0",
    "build_timestamp" : "2015-06-09T13:36:34Z",
    "build_snapshot" : false,
    "lucene_version" : "4.10.4"
  },
  "tagline" : "You Know, for Search"
}

使用浏览器访问 http://YourServerIP:9200/_search 返回：

{
  "took" : 1,
  "timed_out" : false,
  "_shards" : {
    "total" : 0,
    "successful" : 0,
    "failed" : 0
  },
  "hits" : {
    "total" : 0,
    "max_score" : 0.0,
    "hits" : [ ]
  }
}

python操作索引

提交索引

ElasticSearch 提供了多种语言的客户端API，参考 guide，以下提供了python客户端的测试代码：

es = Elasticsearch(YourServerIP)
indexs = []
def addIndex(f):
  global indexs
  for line in f:
    try:
      print line
      index = {
               "_index": "news-index",
               "_type": "news",
               "_source": {
                           "content": line,
                           "timestamp": datetime.now()
                           }
               }
      indexs.append(index)
    except:
      pass

for item in files:
  f = codecs.open('cnlg.txt', encoding='utf-8')
  addIndex(f)

helpers.bulk(es, indexs)

files 为保存着新闻标题的文件，仅作为测试 Elasticsearch 的功能。

在浏览器中进行搜索请求

在浏览器中输入以下命令进行搜索请求：

http://YourServerIP/news-index/_search?pretty=true

浏览器中显示如下内容：

{
   "took": 3,
   "timed_out": false,
   "_shards": {
      "total": 5,
      "successful": 5,
      "failed": 0
   },
   "hits": {
      "total": 110031,
      "max_score": 1,
      "hits": [
         {
            "_index": "news-index",
            "_type": "news",
            "_id": "AU5SY3xQFLGrdE9OAPd3",
            "_score": 1,
            "_source": {
               "content": "龙港体育馆(在建)随拍 ……\n",
               "timestamp": "2015-07-03T13:28:22.448000"
            }
         },
         ...
         ...
         ...
         {
            "_index": "news-index",
            "_type": "news",
            "_id": "AU5SY3xQFLGrdE9OAPel",
            "_score": 1,
            "_source": {
               "content": "龙跃路必成咖啡什么情况？打斗\n",
               "timestamp": "2015-07-03T13:28:22.454000"
            }
         }
      ]
   }
}

使用python进行搜索请求

测试代码如下：

es = Elasticsearch(YourServerIP)
res = es.search(index='news-index', body={"query": {"match_all": {}}})
for hit in res['hits']['hits']:
  print("%(timestamp)s: %(content)s" % hit["_source"])

成功执行代码后输出如下内容：

2015-07-03T13:28:22.448000: 龙港体育馆(在建)随拍 ……
2015-07-03T13:28:22.449000: 我记得当年龙港镇有出了一本龙港历史的书，谁有见到过啊？
2015-07-03T13:28:22.450000: 警方为此开展为期两个多月的“打侵财防盗骗”行动
2015-07-03T13:28:22.451000: 一周天气预报（北风和东北风继续吹）
...

结论

ElasticSearch 的安装相当简单，根据官方提供的文档，两个小时内就能完成以上试验。本篇只是最基础的安装和测试，若要应用到生产中，还有更多内容要深入掌握。