本篇文章為大家展示了用SQL查詢Elasticsearch的插件Elasticsearch-sql怎么用,內(nèi)容簡明扼要并且容易理解,絕對能使你眼前一亮,通過這篇文章的詳細(xì)介紹希望你能有所收獲。
創(chuàng)新互聯(lián)主要從事成都網(wǎng)站設(shè)計、網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)東安,十載網(wǎng)站建設(shè)經(jīng)驗,價格優(yōu)惠、服務(wù)專業(yè),歡迎來電咨詢建站服務(wù):028-86922220
Elasticsearch的查詢語言(DSL)真是不好寫,偏偏查詢的功能千奇百怪,filter/query/match/agg/geo各種各樣,不管你是通過封裝JSON還是通過python/java的api進(jìn)行封裝,都非常不方便。
最近發(fā)現(xiàn)了一個插件,Elasticsearch-SQL可以用sql查詢Elasticsearch,感覺這個輪子造的真是好。
Elasticsearch-sql的項目地址:https://github.com/NLPchina/elasticsearch-sql
1、簡介
Elasticsearch-sql實現(xiàn)的功能:
1)插件式的安裝
2)SQL查詢
3)超越SQL之外的查詢
4)對JDBC方式的支持
2、插件式的安裝
安裝方法和elasticsearch-head的安裝方法類似:
我們使用的es版本是2.1.1,如果你用的是不同的版本,可以在https://github.com/NLPchina/elasticsearch-sql找到支持。
$ cd ~/elasticsearch-2.1.1
$./bin/plugin install https://github.com/NLPchina/elasticsearch- sql/releases/download/2.1.1.1/elasticsearch-sql-2.1.1.1.zip
如果成功,命令行打印如下東東:
[bigdata-dw@bigdata-arch-client10 es2.1.1]$ ./bin/plugin install https://github.com/NLPchina/elasticsearch-sql/releases/download/2.1.1.1/elasticsearch-sql-2.1.1.1.zip
-> Installing from https://github.com/NLPchina/elasticsearch-sql/releases/download/2.1.1.1/elasticsearch-sql-2.1.1.1.zip...
Trying https://github.com/NLPchina/elasticsearch-sql/releases/download/2.1.1.1/elasticsearch-sql-2.1.1.1.zip ...
Downloading .................................................................................................................................................................................................................................................................................................................................................................................................................................................................DONE
Verifying https://github.com/NLPchina/elasticsearch-sql/releases/download/2.1.1.1/elasticsearch-sql-2.1.1.1.zip checksums if available ...
NOTE: Unable to verify checksum for downloaded plugin (unable to find .sha1 or .md5 file to verify)
Installed sql into /home/bigdata-dw/es2.1.1/plugins/sql
3、SQL查詢
安裝成功以后我們就可以通過sql查詢ES了。
es-sql還提供了web頁面,訪問方式是http://10.93.18.34:9200/_plugin/sql/(如果你使用head,那么你的head訪問應(yīng)該是http://10.93.18.34:9200/_plugin/head/)
這里的ip和port是你安裝es的主機(jī)和http端口。
訪問到的頁面是這樣的
那么你現(xiàn)在有兩種方式可以執(zhí)行你的SQL:
1)在搜索框里直接輸入你的sql了。(我的版本行尾不要寫“;”否則會解析不了SQL)
2)通過http請求如
curl -XPOST http://10.93.18.34:8049/_sql -d 'SELECT * FROM audit where dDelay=-2053867461'
你會收到一個json格式的返回
{
"took": 2,
"timed_out": false,
"_shards": {
"total": 5,
"successful": 5,
"failed": 0
},
"hits": {
"total": 1,
"max_score": 12.549262,
"hits": [{
"_index": "audit",
"_type": "kafka",
"_id": "AVzzK-h_V9seINxbZ2Ox",
"_score": 12.549262,
"_source": {
"timestamp": "1498726500000",
"dCount": 680008,
"dDelay": -2053867461,
"cDelay": 0,
"clanName": "DJ_elk_common",
"checkTime": 1498728360063,
"cCount": 0,
"pCount": 680008,
"topicName": "DJ_elk_common_clean",
"pDelay": 370356423
}
}]
}
}
下面我們簡單說4種類型的sql的書寫方式:
1)query
SELECT * FROM bank WHERE age >30 AND gender = 'm'
2)aggregation
select COUNT(*),SUM(age),MIN(age) as m, MAX(age),AVG(age)
FROM bank GROUP BY gender ORDER BY SUM(age), m DESC
3)delete
DELETE FROM bank WHERE age >30 AND gender = 'm'
4)geo
SELECT * FROM locations WHERE GEO_BOUNDING_BOX(fieldname,100.0,1.0,101,0.0)
5)需要指定index+type
SELECT * FROM indexName/type
6)如何指定路由
select /*! ROUTINGS(salary) */ sum(count) from index where type="salary"
4、對JDBC的支持
上述查詢方式不管是直接在web上輸入sql還是通過http請求。elasticsearch-sql還支持通過jdbc進(jìn)行編程。
上述內(nèi)容就是用SQL查詢Elasticsearch的插件Elasticsearch-sql怎么用,你們學(xué)到知識或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識儲備,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
當(dāng)前文章:用SQL查詢Elasticsearch的插件Elasticsearch-sql怎么用
轉(zhuǎn)載源于:http://muchs.cn/article26/iejccg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供服務(wù)器托管、靜態(tài)網(wǎng)站、電子商務(wù)、App設(shè)計、自適應(yīng)網(wǎng)站、小程序開發(fā)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)