Imply之HTTP推送

转载：https://docs.imply.io/on-prem/tutorial/tranquility-server

在本教程中，您将使用Tranquility Server通过HTTP加载自己的流。

Imply还支持各种批量和流式加载方法。有关其他选项的更多信息，请参阅* Loading data *页面，包括Kafka，Hadoop，HTTP，Storm，Samza，Spark Streaming和您自己的JVM应用程序。

先决条件

你会需要：

Java 8（8u92或更高版本）
Linux，Mac OS X或其他类Unix操作系统（不支持Windows）
至少4GB的RAM

暗示使用OpenJDK构建和认证其版本。我们建议选择提供长期支持和开源许可的发行版。Amazon Corretto和Azul Zulu是两个不错的选择。

开始暗示

如果您已经使用快速入门安装并启动了Imply，则可以跳过此步骤。

首先，从imply.io/get-started下载Imply 2.9.8 并解压缩发布存档。

tar -xzf imply-2.9.8.tar.gz
cd imply-2.9.8

接下来，您需要启动Imply，其中包括Druid， Imply UI和 ZooKeeper。您可以使用包含的监督程序通过单个命令启动所有内容：

bin/supervise -c conf/supervise/quickstart.conf

您应该看到为每个启动的服务打印出一条日志消息。您可以通过var/sv/使用其他终端查看目录来查看任何服务的详细日志。

稍后，如果您想停止服务，请按CTRL-C终端中的监督程序。如果要在停止服务后进行干净启动，请删除该var/目录，然后重新启动。

启用Tranquility Server

Imply包括Tranquility Server以支持通过HTTP加载数据。要在Imply基于快速入门的配置中启用此功能：

在你的conf/supervise/quickstart.conf，取消注释该tranquility-server行。
停止bin / supervise命令（CTRL-C或bin/service --down），然后再次运行重新启动它bin/supervise -c conf/supervise/quickstart.conf。

作为监督输出的一部分，你应该看到类似的东西：

Running command[tranquility-server], logging to[/home/imply/imply-2.9.8/var/sv/tranquility-server.log]: bin/tranquility server -configFile conf-quickstart/tranquility/server.json

您可以检查日志文件var/sv/tranquility-server.log以确认服务器正在正常启动。

发送数据

我们发一些数据吧！

我们已经包含了一个脚本，可以生成一些随机样本指标以加载到此数据源中。要使用它，请运行：

bin/generate-example-metrics | curl -XPOST -H'Content-Type: application/json' --data-binary @- http://localhost:8200/v1/post/tutorial-tranquility-server

这将打印如下：

{"result":{"received":25,"sent":25}}

这表明HTTP服务器收到了您的25个事件，并向德鲁伊发送了25个事件。如果在启用Tranquility Server后运行太快，此命令可能会生成“连接被拒绝”错误，这意味着服务器尚未启动。它应该在几秒钟内启动。该命令也可能需要几秒钟才能完成第一次运行它，在此期间德鲁伊资源被分配给摄取任务。完成后，后续POST将很快完成。

一旦将数据发送到德鲁伊，您就可以立即查询它。

查询数据

发送数据后，您可以使用任何支持的查询方法（包括可视化，SQL和API）立即查询数据。首先，尝试SQL查询：

$ bin/dsql
dsql> SELECT server, SUM("count") AS "events", COUNT(*) AS "rows" FROM "tutorial-tranquility-server" GROUP BY server;
┌──────────────────┬────────┬──────┐
│ server           │ events │ rows │
├──────────────────┼────────┼──────┤
│ www1.example.com │      9 │    6 │
│ www2.example.com │     11 │    6 │
│ www3.example.com │     11 │    5 │
│ www4.example.com │     11 │    7 │
│ www5.example.com │      8 │    4 │
└──────────────────┴────────┴──────┘
Retrieved 5 rows in 0.02s.

你可以看到，由于德鲁伊的OLAP汇总功能，COUNT(*)可能会返回一个小于SUM("count")。

接下来，尝试在Imply中配置数据立方体：

在http：// localhost：9095 /导航到Imply UI 。
单击标题栏右上角的加号图标，然后选择“新建数据立方体”。
选择源“druid：tutorial-tranquility-server”并确保选中“自动填充尺寸和尺寸”。
单击“下一步：配置数据立方体”。
单击“创建多维数据集”。您应该看到确认消息“Data cube created”。
单击右上角的主页图标，然后选择刚刚创建的“Tutorial Tranquility Server”多维数据集，查看新数据多维数据集。

加载您自己的数据

到目前为止，您已使用我们已包含在分发中的摄取规范加载数据。每个摄取规范旨在与特定数据集一起使用。您可以通过编写自定义提取规范来加载自己的数据集。

要自定义Tranquility Server提取，您可以编辑conf-quickstart/tranquility/server.json配置文件。有关如何解释和修改配置的更多详细信息，请参阅Tranquility文档。更新配置后，您可以通过运行以下命令重新启动Tranquility Server：

bin/service --restart tranquility-server

请注意，在发送自己的流数据时，必须确保时间戳足够快（在当前时间的windowPeriod内）。较旧的活动不会发送给德鲁伊。有关详细信息，请参阅Tranquility文档的 Segment粒度和windowPeriod部分。

进一步阅读

阅读我们更多关于加载数据的摄入文档。
通过教程：编辑摄取规范，了解如何编辑摄取规范以加载您自己的数据。
有关参考文档，请参阅Tranquility文档。