安装部署

环境准备

  • 安装并启动 MySQL 5.7+

  • 初始化数据库 inlong-manager 目录下有 sql/apache_inlong_manager.sql文件，通过下述命令加载此文件，完成表结构及基础数据的初始化：

    1. # 通过用户名和密码，创建DB和表：
    2. mysql -uDB_USER -pDB_PASSWD < sql/apache_inlong_manager.sql

添加依赖

修改配置

前往 inlong-manager 目录，修改 conf/application.properties 文件：

  1. # manager 服务的端口号
  2. server.port=8083
  4. # 默认使用的配置文件为 dev
  5. spring.profiles.active=dev

上面指定了 dev 配置，接下来修改 conf/application-dev.properties 文件：

如果指定了 test 或 prod，则修改对应的 application-xxx.properties 文件。

  1. spring.datasource.druid.url=jdbc:mysql://127.0.0.1:3306/apache_inlong_manager?useSSL=false&allowPublicKeyRetrieval=true&characterEncoding=UTF-8&nullCatalogMeansCurrent=true&serverTimezone=GMT%2b8
  2. spring.datasource.druid.username=root
  3. spring.datasource.druid.password=inlong

配置 Flink 插件

InLong Manager 可启动 Sort 任务进行数据的消费和落地，需要先配置 Flink 环境信息。配置文件为 plugins/flink-sort-plugin.properties。

  1. # Flink version, support [1.13|1.15]
  2. flink.version=1.13
  3. # Flink host split by coma if more than one host, such as 'host1,host2'
  4. flink.rest.address=127.0.0.1
  5. # Flink port
  6. flink.rest.port=8081
  7. # Flink job manager port
  8. flink.jobmanager.port=6123
  9. # InLong Audit Proxy Address
  10. metrics.audit.proxy.hosts=127.0.0.1:10081

启动服务

  1. bash +x bin/startup.sh

集群初始化

当所有容器都成功启动后，可以访问 InLong Dashboard 地址http://localhost，并使用以下默认账号登录:

  1. User: admin
  2. Password: inlong

创建集群标签

页面点击 [集群管理]->[标签管理]->[新建]，指定集群标签名称和负责人： 安装部署 - 图1

安装部署 - 图2警告

由于各个组件默认上报集群标签为 default_cluster，请勿使用其它名称。

注册 MQ 集群

只用注册你选择的 MQ 类型集群。

  • 选择 1：注册 Pulsar 集群 页面点击 [集群管理]->[集群管理]->[新建集群]，注册 Pulsar 集群： 安装部署 - 图3

  • 选择 2：注册 TubeMQ 集群 页面点击 [集群管理]->[集群管理]->[新建集群]，注册 TubeMQ 集群： 安装部署 - 图4

  • 选择 3：注册 Kafka 集群 页面点击 [集群管理]->[集群管理]->[新建集群]，注册 Kafka 集群： 安装部署 - 图5

安装部署 - 图6备注

集群标签选择刚创建的 default_cluster，然后配置 MQ 集群信息。

(可选) 开启OpenAPI认证

开启认证

Manager 提供 OpenAPI 安全访问认证，默认关闭。如需开启，在 conf/application.properties 打开：

  1. # Manager OpenAPI 安全认证开关
  2. openapi.auth.enabled=true

配置认证

相关组件需配置由 Manager 分配的认证 secret id 和 secret key，例如 (建议使用新分配的替代默认值)：

Agent conf 目录下 agent.properties：

  1. agent.manager.auth.secretId=admin
  2. agent.manager.auth.secretKey=87haw3VYTPqK5fK0

Dataproxy conf 目录下 common.properties：

  1. manager.auth.secretId=admin
  2. manager.auth.secretKey=87haw3VYTPqK5fK0

创建认证Key

管理员可以登录应龙 Dashboard 管理端来创建 secret id 和 secret key： 系统管理->用户管理->新建账号.