环境准备
- es 环境
version: "3"
services:
es01:
image: elasticsearch:7.3.2
container_name: es01
// 开启sql 以及认证
environment:
- "http.host=0.0.0.0"
- "transport.host=localhost"
- "network.host=0.0.0.0"
- "http.cors.enabled=true"
- "http.cors.allow-origin=*"
- "xpack.ml.enabled=false"
- "xpack.security.enabled=true"
- "xpack.sql.enabled=true"
ulimits:
memlock:
soft: -1
hard: -1
ports:
- 9200:9200
初始化账户（进入容器）
elasticsearch-setup-passwords auto -v
- es 数据
app.js
const { Client } = require('@elastic/elasticsearch')
const client = new Client({ node: 'http://elastic:ed824a5iPV33lrO7MOz0@localhost:9200' })
async function run () {
// Let's start by indexing some data
await client.index({
index: 'game',
// type: '_doc', // uncomment this line if you are using Elasticsearch ≤ 6
body: {
character: 'Ned Stark',
quote: 'Winter is coming.'
}
})
await client.index({
index: 'game',
// type: '_doc', // uncomment this line if you are using Elasticsearch ≤ 6
body: {
character: 'Daenerys Targaryen',
quote: 'I am the blood of the dragon.'
}
})
await client.index({
index: 'game',
// type: '_doc', // uncomment this line if you are using Elasticsearch ≤ 6
body: {
character: 'Tyrion Lannister',
quote: 'A mind needs books like a sword needs a whetstone.'
}
})
// here we are forcing an index refresh, otherwise we will not
// get any result in the consequent search
await client.indices.refresh({ index: 'game' })
// Let's search!
const { body } = await client.search({
index: 'game',
// type: '_doc', // uncomment this line if you are using Elasticsearch ≤ 6
body: {
query: {
match: { quote: 'winter' }
}
}
})
console.log(body.hits.hits)
}
run().catch(console.log)
cube.js 配置
.env
CUBEJS_DB_URL=http://elastic:ed824a5iPV33lrO7MOz0@localhost:9200
CUBEJS_DB_ELASTIC_QUERY_FORMAT=json
CUBEJS_DEV_MODE=true
CUBEJS_DB_TYPE=elasticsearch
CUBEJS_API_SECRET=b9a87765c28b91d570e51647c3e7cbb5a71364147bdfbef65ffa307808ef9128b98142883a541e48a8b8517d0e02d7e8344ac694c29e7b0f09a3ee0df10755d8
package.json
{
"name": "myappdemo",
"version": "0.0.1",
"private": true,
"scripts": {
"dev": "./node_modules/.bin/cubejs-server"
},
"template": "docker",
"templateVersion": "0.26.44",
"devDependencies": {
"@cubejs-backend/cubestore-driver": "^0.28.8",
"@cubejs-backend/elasticsearch-driver": "^0.28.8",
"@cubejs-backend/server": "^0.28.8"
}
}
访问效果
说明
对于database 的处理有点问题，多了main，都是可以使用的
参考资料
https://www.npmjs.com/package/@elastic/elasticsearch
https://cube.dev/docs/reference/environment-variables#database-connection