安装并启动 MySQL 5.7+
初始化数据库 inlong-manager
目录下有 sql/apache_inlong_manager.sql
文件,通过下述命令加载此文件,完成表结构及基础数据的初始化:
# 通过用户名和密码,创建DB和表: mysql -uDB_USER -pDB_PASSWD < sql/apache_inlong_manager.sql
inlong-sort/connectors
目录。lib/
目录。前往 inlong-manager
目录,修改 conf/application.properties
文件:
# manager 服务的端口号 server.port=8083 # 默认使用的配置文件为 dev spring.profiles.active=dev
上面指定了 dev 配置,接下来修改 conf/application-dev.properties
文件:
如果指定了 test 或 prod,则修改对应的 application-xxx.properties 文件。
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 spring.datasource.druid.username=root spring.datasource.druid.password=inlong
InLong Manager 可启动 Sort 任务进行数据的消费和落地,需要先配置 Flink 环境信息。配置文件为 plugins/flink-sort-plugin.properties
。
# Flink host split by coma if more than one host, such as 'host1,host2' flink.rest.address=127.0.0.1 # Flink port flink.rest.port=8081 # Flink job manager port flink.jobmanager.port=6123 # InLong Audit Proxy Address metrics.audit.proxy.hosts=127.0.0.1:10081
bash +x bin/startup.sh
若使用 Pulsar 作为数据缓存的消息队列,则需要添加其配置到 InLong-Manager 中:
打开 Inlong-Dashboard 页面(默认是 http://127.0.0.1),在 [集群管理] 页签中选择添加 Pulsar 集群:
点击 [新建集群] 按钮,在弹出的框中填写 集群名称、集群标签、责任人、AdminUrl、ServiceUrl 及默认租户等必填信息即可保存。
说明:[集群标签] 是一个逻辑概念,同名的标签将被视为同一套集群,比如相同集群标签的 DataProxy 集群和 Pulsar 集群,属于同一套集群。
填写示例:
若使用 InLong TubeMQ 作为数据缓存的消息队列,则需要添加其配置到 InLong-Manager 中:
与上述 Pulsar 集群的添加入口相似,填写示例如下:
Manager 提供 OpenAPI 安全访问认证,默认关闭。如需开启,在 conf/application.properties
打开:
# Manager OpenAPI安全认证开关 openapi.auth.enabled=true
相关组件需配置由 Manager 分配的认证 secret id 和 secret key,例如 (建议使用新分配的替代默认值):
Agent
conf 目录下 agent.properties
:
agent.manager.auth.secretId=admin agent.manager.auth.secretKey=87haw3VYTPqK5fK0
Dataproxy
conf 目录下 common.properties
:
manager.auth.secretId=admin manager.auth.secretKey=87haw3VYTPqK5fK0
管理员可以登录应龙 Dashboard 管理端来创建 secret id 和 secret key: 系统管理->用户管理->新建账号.