This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong-website.git


The following commit(s) were added to refs/heads/master by this push:
     new 45312c8e847 [INLONG-989][Doc] Add HTTP report usage demo in Quick 
Start (#1001)
45312c8e847 is described below

commit 45312c8e84755823b83440e791551dc8987a856b
Author: Goson Zhang <4675...@qq.com>
AuthorDate: Sat Sep 28 20:18:37 2024 +0800

    [INLONG-989][Doc] Add HTTP report usage demo in Quick Start (#1001)
---
 docs/quick_start/data_http_report/_category_.json  |   4 ++
 docs/quick_start/data_http_report/http_report.md   |  55 +++++++++++++++++++++
 .../data_http_report/img/http_data_preview_en.png  | Bin 0 -> 63494 bytes
 .../data_http_report/img/http_data_view_en.png     | Bin 0 -> 20893 bytes
 .../data_http_report/img/http_dataproxy_en.png     | Bin 0 -> 26970 bytes
 .../data_http_report/img/http_group_stream_en.png  | Bin 0 -> 48136 bytes
 .../data_http_report/img/http_stream_define_en.png | Bin 0 -> 41117 bytes
 .../quick_start/data_http_report/http_report.md    |  55 +++++++++++++++++++++
 .../data_http_report/img/http_data_preview_cn.png  | Bin 0 -> 63609 bytes
 .../data_http_report/img/http_data_view_cn.png     | Bin 0 -> 21355 bytes
 .../data_http_report/img/http_dataproxy_cn.png     | Bin 0 -> 29109 bytes
 .../data_http_report/img/http_group_stream_cn.png  | Bin 0 -> 49126 bytes
 .../data_http_report/img/http_stream_define_cn.png | Bin 0 -> 39714 bytes
 13 files changed, 114 insertions(+)

diff --git a/docs/quick_start/data_http_report/_category_.json 
b/docs/quick_start/data_http_report/_category_.json
new file mode 100644
index 00000000000..1539f4f8940
--- /dev/null
+++ b/docs/quick_start/data_http_report/_category_.json
@@ -0,0 +1,4 @@
+{
+  "label": "HTTP Report",
+  "position": 4
+}
\ No newline at end of file
diff --git a/docs/quick_start/data_http_report/http_report.md 
b/docs/quick_start/data_http_report/http_report.md
new file mode 100644
index 00000000000..957258c5324
--- /dev/null
+++ b/docs/quick_start/data_http_report/http_report.md
@@ -0,0 +1,55 @@
+---
+title: HTTP Report Example
+sidebar_position: 1
+---
+
+In the following content, we will use a complete example to introduce how to 
use HTTP to report data, quickly verify whether the applied {groupId, streamId} 
is effective, and whether the data is accepted by InLong DataProxy and 
correctly written to the MQ cluster.
+
+## Prepare resources
+### Apply for InLong group and stream
+We need to apply for {groupId, streamId} in InLong Manager first. As shown in 
the following figure, we have applied for {test_http, test_stream} information 
and the administrator has approved it:
+![prepare group and stream](img/http_group_stream_en.png)
+
+In the application report stream, we defined that the data of this report 
stream is reported in CSV format. The data content consists of three fields 
(ID, Name, Desc) separated by vertical bars ("|"):
+![define report stream](img/http_stream_define_en.png)
+
+### Find the IP and port of the DataProxy node that supports HTTP access
+InLong supports direct data reporting via HTTP. In this reporting example, we 
directly select a DataProxy that supports HTTP reporting from the resource 
details page of the InLong group to report the message. In the demonstration 
environment, the HTTP receiving port opened by DataProxy is 47805, as shown 
below:
+![DataProxy information](img/http_dataproxy_en.png)
+
+At this point, we have obtained the InLong group and stream information 
required for data reporting, as well as the DataProxy node IP and port 
information to be reported by HTTP reporting. Next, we can report data through 
HTTP to verify whether the requested InLong group and stream, pipeline are 
available. 
+
+## Report data via HTTP
+According to the HTTP reporting protocol requirements of InLong, we use curl 
tool to construct an HTTP instruction as shown below for execution. In the body 
part, we construct a record containing three field values according to the 
format definition of test_stream. {dataproxy_ip:dataproxy_httpport} is the 
DataProxy IP and port for receiving the reported message. You can replace it 
with the corresponding information in your environment:
+
+```bash
+curl -X POST -d 
'groupId=test_http&streamId=test_stream&dt=data_time&body=1|name_1|desc_record_one&cnt=1'
 http://{dataproxy_ip:dataproxy_httpport}/dataproxy/message
+```
+- Parameter Description:
+
+| parameter | meaning                               | Remark  |
+|-----------|---------------------------------------|---------|
+| groupId   | Data stream group id                  |         |
+| streamId  | Data stream ID                        |         |
+| body      | Data content to be pushed             |         |
+| dt        | Data time to be pushed                |timestamp in millisecond  
   |
+| cnt       | The count of data pieces to be pushed |         |
+
+- Return Value:
+
+| return value | meaning |
+|--------------|---------|
+| 0            | Success |
+| !=0          | Failure |
+
+## Check the reported data
+We use the data preview function of the data stream test_http:test_stream to 
view the HTTP reporting status. This function directly samples the latest data 
from the MQ cluster corresponding to the data stream:
+![data_preview](img/http_data_preview_en.png)
+
+We can see that the data just reported has been successfully written to the MQ 
cluster:
+![viewed_data](img/http_data_view_en.png)
+
+At this point, we quickly and clearly know that the requested InLong group and 
stream, as well as the pipeline resources, are all available.
+
+## FAQ
+The return code and error message in the HTTP response will clearly indicate 
the specific cause of the error, such as the group or stream does not exist, 
the reporting protocol format is not equal, etc., and the problem can be 
quickly solved by adjusting according to the corresponding error prompt or 
aligning with the system administrator.
\ No newline at end of file
diff --git a/docs/quick_start/data_http_report/img/http_data_preview_en.png 
b/docs/quick_start/data_http_report/img/http_data_preview_en.png
new file mode 100644
index 00000000000..534fc7d0b62
Binary files /dev/null and 
b/docs/quick_start/data_http_report/img/http_data_preview_en.png differ
diff --git a/docs/quick_start/data_http_report/img/http_data_view_en.png 
b/docs/quick_start/data_http_report/img/http_data_view_en.png
new file mode 100644
index 00000000000..09549859497
Binary files /dev/null and 
b/docs/quick_start/data_http_report/img/http_data_view_en.png differ
diff --git a/docs/quick_start/data_http_report/img/http_dataproxy_en.png 
b/docs/quick_start/data_http_report/img/http_dataproxy_en.png
new file mode 100644
index 00000000000..c0bcde590ed
Binary files /dev/null and 
b/docs/quick_start/data_http_report/img/http_dataproxy_en.png differ
diff --git a/docs/quick_start/data_http_report/img/http_group_stream_en.png 
b/docs/quick_start/data_http_report/img/http_group_stream_en.png
new file mode 100644
index 00000000000..8bc7a95dd2c
Binary files /dev/null and 
b/docs/quick_start/data_http_report/img/http_group_stream_en.png differ
diff --git a/docs/quick_start/data_http_report/img/http_stream_define_en.png 
b/docs/quick_start/data_http_report/img/http_stream_define_en.png
new file mode 100644
index 00000000000..e76d9c9f433
Binary files /dev/null and 
b/docs/quick_start/data_http_report/img/http_stream_define_en.png differ
diff --git 
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/http_report.md
 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/http_report.md
new file mode 100644
index 00000000000..f7eba744f30
--- /dev/null
+++ 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/http_report.md
@@ -0,0 +1,55 @@
+---
+title: HTTP 上报示例
+sidebar_position: 1
+---
+
+在下面的内容中,我们将通过一个完整的示例介绍如何使用 HTTP 上报数据,快速验证申请的 {groupId, streamId} 是否已生效,数据是否被 
InLong DataProxy 接纳并正确地写入到 MQ 集群。
+
+## 准备上报资源
+### 申请 InLong group 和 stream
+我们需要先在 InLong 的 Manager 里申请上报所需的 {groupId, streamId} 信息,如下图示,我们已经申请了 
{test_http, test_stream} 信息并且管理员已审批通过:
+![group 和 stream 准备](img/http_group_stream_cn.png)
+
+在申请的上报流里,我们定义了该上报流的数据采用 CSV 格式上报数据,数据内容由三个字段(ID,Name,Desc)组成,并以竖线("|")分隔:
+![数据流定义](img/http_stream_define_cn.png)
+
+### 查找支持 HTTP 接入的 DataProxy 节点 IP 及端口号
+InLong 支持通过 HTTP 直接上报数据,这个上报示例里我们直接从 InLong group 的资源详情页面选一台支持 HTTP 上报的 
DataProxy 进行消息上报。在演示环境里 DataProxy 开启的 HTTP 接收端口是 47805,如下图示:
+![DataProxy 信息](img/http_dataproxy_cn.png)
+
+至此,我们已经获得了数据上报所需要的 InLong group 和 stream 信息,以及 HTTP 上报所要上报的 DataProxy 节点 IP 
及端口信息,接下来我们就可以通过 HTTP 上报数据,验证申请的 InLong group 和 stream,以及管道是否可用。
+
+## 通过 HTTP 上报数据
+按照 InLong 的 HTTP 上报协议要求,我们用 curl 构造一个如下示例的 HTTP 指令进行执行,其中 body 部分我们按照 
test_stream 的格式定义构造包含 3 个字段值的记录, {dataproxy_ip:dataproxy_httpport} 为接收上报消息的 
DataProxy IP 及端口,大家可以替换为各自环境里的对应信息:
+```bash
+curl -X POST -d 
'groupId=test_http&streamId=test_stream&dt=data_time&body=1|name_1|desc_record_one&cnt=1'
 http://{dataproxy_ip:dataproxy_httpport}/dataproxy/message
+```
+
+- 参数说明:
+
+| 参数       | 含义       | 备注  |
+|----------|----------|-----|
+| groupId  | 数据流组 id  |     |
+| streamId | 数据流 ID   |     |
+| body     | 推送的数据内容  |     |
+| dt       | 推送的数据时间  |毫秒为单位的时间戳 |
+| cnt      | 推送条数     |     |
+
+- 返回值:
+
+| 返回码 | 含义  |
+|-----|-----|
+| 0   | 成功  |
+| 非0  | 失败  |
+
+## 检查数据上报情况
+我们通过数据流 test_http:test_stream 的数据预览功能查看 HTTP 上报情况,该功能直接从数据流对应的 MQ 集群抽检最新数据:
+![数据预览](img/http_data_preview_cn.png)
+
+我们可以看到刚才上报的数据已经成功写入 MQ 集群:
+![数据呈现](img/http_data_view_cn.png)
+
+到这里,我们就可以快速、清楚地知道申请的 InLong group 和 stream,以及管道资源已经可用。
+
+## 常见问题
+HTTP 上报的返回结果里返回码及错误信息会很清楚指出具体错误原因,比如 group 或 stream 
不存在,上报协议格式不对等,按照对应的错误提示进行调整或者与系统管理员进行对齐即可快速解决问题。
\ No newline at end of file
diff --git 
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_data_preview_cn.png
 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_data_preview_cn.png
new file mode 100644
index 00000000000..89e6c553376
Binary files /dev/null and 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_data_preview_cn.png
 differ
diff --git 
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_data_view_cn.png
 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_data_view_cn.png
new file mode 100644
index 00000000000..434b97efdf6
Binary files /dev/null and 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_data_view_cn.png
 differ
diff --git 
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_dataproxy_cn.png
 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_dataproxy_cn.png
new file mode 100644
index 00000000000..6309d08fdcf
Binary files /dev/null and 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_dataproxy_cn.png
 differ
diff --git 
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_group_stream_cn.png
 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_group_stream_cn.png
new file mode 100644
index 00000000000..8b39e0110f2
Binary files /dev/null and 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_group_stream_cn.png
 differ
diff --git 
a/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_stream_define_cn.png
 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_stream_define_cn.png
new file mode 100644
index 00000000000..551f7e642be
Binary files /dev/null and 
b/i18n/zh-CN/docusaurus-plugin-content-docs/current/quick_start/data_http_report/img/http_stream_define_cn.png
 differ

Reply via email to