如何为 Presto 和 InfluxDB 创建自定义连接器

How to create a custom connector for Presto and InfluxDB

我正在尝试为 Presto 和 InfluxDB 创建自定义连接器,以便 Presto 可以 运行 SQL 查询 InfluxDB。是否已经有此类连接器可用的示例?

Connectors are the source of all data for queries in Presto. Even if your data source doesn’t have underlying tables backing it, as long as you adapt your data source to the API expected by Presto, you can write queries against this data.

我找到的关于编写连接器的唯一文档是: https://prestodb.io/docs/current/develop/example-http.html

如果谁有其他例子,可以分享一下吗?

presto 源代码树中有多个连接器。

当您连接到具有 JDBC 驱动程序的数据源时(可能不是您的情况),扩展 presto-base-jdbc 驱动程序几乎可以满足您的所有需求。例如参见 [​​=12=]

当您连接到未启用 JDBC 的数据源时(或者您需要更多 presto-base-jdbc 可能的数据源),您需要实现所有相关的连接器接口。除了 Java 接口和源代码外,没有很好的文档,但您可以按照示例进行操作,例如https://github.com/trinodb/trino/tree/master/presto-cassandra, https://github.com/trinodb/trino/tree/master/presto-accumulo

还有一个选择是 Greg Leclercq 提出的实施 Thrift 连接器的建议。请参阅他的 以获取指导。

如果您更喜欢使用 Java 以外的编程语言进行编码,另一种选择是实施 Thrift 服务并使用 Thrift connector