原生查询

[!WARNING] Apache Druid支持两种查询语言,Druid SQL原生查询,该文档描述原生查询语言。有关Druid SQL如何选择运行SQL查询时要使用的原生查询类型的信息,请查看 SQL文档

Druid中的原生查询是JSON对象,通常发送给Broker或Router进程。查询可以这样发布:

curl -X POST '<queryable_host>:<port>/druid/v2/?pretty' -H 'Content-Type:application/json' -H 'Accept:application/json' -d @<query_json_file>

Druid的原生查询语言是JSON over HTTP,尽管社区的许多成员已经用其他语言提供了不同的 客户端库 来查询Druid。

Content-Type/Accept Header也可以采用"application/x-jackson-smile":

curl -X POST '<queryable_host>:<port>/druid/v2/?pretty' -H 'Content-Type:application/json' -H 'Accept:application/x-jackson-smile' -d @<query_json_file>

注意:如果未提供Accept header,则默认为"Content Type" header的值。

Druid的原生查询级别相对较低,与内部执行计算的方式密切相关。Druid查询被设计成轻量级的,并且非常快速地完成。这意味着对于更复杂的分析,或者构建更复杂的可视化,可能需要多个Druid查询。

即使查询通常是向Broker或Router发出的,但是它们也可以被 Historical进程 和运行流摄取任务的 peon(任务jvm) 接受。如果您想查询由特定进程提供服务的特定段的结果,这可能很有价值。

可用的查询

Druid有许多不同场景的查询类型。查询由各种JSON属性组成,Druid针对不同的场景有不同类型的查询。各种查询类型的文档描述了可以设置的所有JSON属性。

聚合查询

元数据查询

其他查询

应该使用哪种类型的查询

对于聚合查询,如果有多个查询可以满足您的需求,我们通常建议尽可能使用Timeseries或TopN,因为Druid针对它们的场景做了专门优化的。如果两者都不适合,则应该使用GroupBy查询,这是最灵活的。

查询取消

可以使用查询的唯一标识符显式地取消查询。如果查询标识符是在查询时设置的,或者是已知的,那么可以在Broker或Router上使用以下接口来取消查询。

DELETE /druid/v2/{queryId}

例如:如果查询ID是 abc123, 查询可以如下取消:

curl -X DELETE "http://host:port/druid/v2/abc123"

查询错误

如果查询失败,您将得到一个HTTP 500响应,其中包含具有以下结构的JSON对象:

{
  "error" : "Query timeout",
  "errorMessage" : "Timeout waiting for task.",
  "errorClass" : "java.util.concurrent.TimeoutException",
  "host" : "druid1.example.com:8083"
}

如果查询请求由于受到 query scheduler laning configuration 的限制而失败,则为HTTP 429响应,该响应具有与错误响应相同的JSON对象架构,但 errorMessage 格式为:"Total query capacity exceeded"或"query capacity exceeded for lane 'low'"。

响应中的字段是:

字段 描述
error 定义明确的错误代码(如下表格)
errorMessage 包含有关错误的详细信息的自由格式消息。可能为空。
errorClass 导致此错误的异常的类。可能为空。
host 发生此错误的主机。可能为空。

可能的错误码字段如下:

错误码 描述
Query timeout 查询超时
Query interrupted 查询被中断,可能是因为JVM关闭
Query cancelled 查询通过"查询取消API"取消
Resource limit exceeded 查询超出了配置的资源限制(例如groupBy maxResults)
Unauthorized request 由于安全策略,查询被拒绝。用户已被识别,但未识别出用户的访问权限。
Unsupported operation 查询试图执行不受支持的操作。当使用未记录的功能或使用未完全实现的扩展时,可能会发生这种情况
Unknown exception 发生了其他异常。请检查errorMessage和errorClass以获取详细信息,但请记住,这些字段的内容是自由格式的,并且可能会随着版本的不同而变化

渝ICP备16001958号 | Copyright © 2020 apache-druid.cn All right reserved,powered by Gitbook最近一次修改时间: 2021-11-17 15:22:04

results matching ""

    No results matching ""