Proton Ingest REST API

You can run INSERT INTO [stream](/column1, column2) VALUES (..) SQL to insert data to Timeplus Proton or timeplusd in Timeplus Enterprise. You can also call the ingestion REST API to push data to Timeplus Proton or timeplusd, with any preferred languages. Timeplus Enterprise also provides REST API in the application sever. Comparing to that REST API, the Proton/Timeplusd Ingest REST API performs better, but doesn't support API Key, or flexible payload schema.

先决条件

从 Proton 容器中暴露端口 3218

默认情况下，Proton 采集 REST API 位于端口 3218 上。 Please start the Proton container with the 3218 port exposed. 例如：

docker run -d -p 3218:3218 --pull always --name proton ghcr.io/timeplus-io/proton:latest

在 Proton 中创建流

You need to create a stream in Timeplus via CREATE STREAM. 应设置具有正确名称和类型的列。

首先运行 SQL 客户端

然后运行以下 SQL 来创建流。

将数据推送到 Timeplus

实时数据摄取的端点是 'http://localhost:3218/proton/v1/ingest/streams/{stream_name}\`。 HTTP 方法是 POST。

索取样品：

Node.js

curl

Python

Java

备注：

• columns 是一个字符串数组，其中包含列名
• 数据是一个数组数组。 每个嵌套数组代表一行数据。 值顺序必须与 “列” 中完全相同的顺序匹配。

例如：

您也可以使用我们的软件开发工具包来提取数据，而无需处理 REST API 的低级细节。