› ›

SQL

SQL编辑

Elasticsearch SQL 是一个 X-Pack 组件，允许对 Elasticsearch 执行类似 SQL 的实时查询。无论是使用 REST 接口、命令行还是 JDBC，任何客户端都可以使用 SQL 在 Elasticsearch 内部原生搜索和聚合数据。可以将 Elasticsearch SQL 视为一个转换器，它同时理解 SQL 和 Elasticsearch，并通过利用 Elasticsearch 的功能，可以轻松地实时、大规模地读取和处理数据。

在以下示例中，我们将搜索所有字段 house 等于 stark 的文档，以表格视图记录结果，然后操作结果以获得易于浏览的对象。

'use strict'

const { Client } = require('@elastic/elasticsearch')
const client = new Client({
  cloud: { id: '<cloud-id>' },
  auth: { apiKey: 'base64EncodedKey' }
})

async function run () {
  await client.index({
    index: 'game-of-thrones',
    document: {
      character: 'Ned Stark',
      quote: 'Winter is coming.',
      house: 'stark'
    }
  })

  await client.index({
    index: 'game-of-thrones',
    document: {
      character: 'Arya Stark',
      quote: 'A girl is Arya Stark of Winterfell. And I\'m going home.',
      house: 'stark'
    }
  })

  await client.index({
    index: 'game-of-thrones',
    refresh: true,
    document: {
      character: 'Tyrion Lannister',
      quote: 'A Lannister always pays his debts.',
      house: 'lannister'
    }
  })

  const result = await client.sql.query({
    query: "SELECT * FROM \"game-of-thrones\" WHERE house='stark'"
  })

  console.log(result)

  const data = result.rows.map(row => {
    const obj = {}
    for (let i = 0; i < row.length; i++) {
      obj[result.columns[i].name] = row[i]
    }
    return obj
  })

  console.log(data)
}

run().catch(console.log)

« transport.request 更新 »