druid-docs-cn/makeNativeQueries.md at 44f2cf190bd318f35bc2b4fca9356ad38e1c3331

4.9 KiB

Raw Blame History

原生查询

[!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属性。

聚合查询

元数据查询

其他查询

Scan
Search

应该使用哪种类型的查询

对于聚合查询，如果有多个查询可以满足您的需求，我们通常建议尽可能使用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以获取详细信息，但请记住，这些字段的内容是自由格式的，并且可能会随着版本的不同而变化

4.9 KiB Raw Blame History Unescape Escape