好好学习,天天向上,一流范文网欢迎您!
当前位置: >> 计划 >> 学习计划 内容页

DINKY Dinky:一个开箱即用的一站式实时计算平台

Dinky 是一个开箱即用、易扩展的一站式实时计算平台,以 Apache Flink 为内核构建,连接 OLAP 和数据湖等众多框架,致力于流批一体和湖仓一体的建设与实践。

Dinky 项目主要使用 Java 语言开发,基于 Apache 2.0 开源协议,代码托管在 GitHub:

https://github.com/DataLinkDC/dinky

核心特性

下载安装

Apache Flink一站式平台_Dinky实时计算平台_DINKY

推荐使用 Docker 快速体验 Dinky 的功能:

# 拉取镜像
docker pull dinkydocker/dinky-standalone-server:1.2.4-flink1.20
# 运行程序
docker run -p 8888:8888 
--name dinky dinkydocker/dinky-standalone-server:1.2.4-flink1.20

启动服务后,在浏览器里输入以下地址:

http://localhost:8888

DINKY_Apache Flink一站式平台_Dinky实时计算平台

设置初始用户(admin)的密码和相关信息之后DINKY钓鱼网,登录系统。

接下来我们新建一个 Flink 任务,在数据开发页面左侧“项目”标签点击“+”新建根目录:

点击新建的目录,右键创建作业,选择 FlinkSQL 作业类型,填写作业名称,点击确定。

输入以下语句:

CREATE TABLE Orders (
  order_number BIGINT,
  price DECIMAL(32,2),
  buyer ROW,
  order_time TIMESTAMP(3)
) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '1',
  'number-of-rows' = '50'
);
select order_number,price,first_name,last_name,order_time from Orders

Apache Flink一站式平台_Dinky实时计算平台_DINKY

点击“查询”按钮进行调试,启动 local 集群并执行任务,下方控制台会实时显示运行日志,提交成功后会切换到结果选项卡,点击“获取最新数据”即可查看 Select 语句的执行结果。

停止调试,点击“运行”按钮提交任务到集群。

此时DINKY,进入运维中心页面可以看到任务列表:

Dinky实时计算平台_Apache Flink一站式平台_DINKY

点击作业详情按钮即可查看作业的运行状态、日志、监控等信息。

官方文档:

Dinky实时计算平台_DINKY_Apache Flink一站式平台

https://www.dinky.org.cn/docs/next/get_started/overview

总结

Dinky 致力于简化 Flink 任务开发,提升 Flink 任务运维能力,降低 Flink 入门成本,提供一站式的 Flink 任务开发、运维、监控、报警、调度、数据管理等功能。