RabbitMQ快速上手
MQ是消息队列（Message Queue）的简称，是一种用于应用程序之间进行异步通信的技术。消息队列允许应用程序在时间上解耦，从而提高系统的可靠性和可伸缩性。通过将消息发送到队列中，发送者和接收者可以在不直接相互通信的情况下进行通信。这种方式使得系统可以更加灵活地处理高负载、异步任务和系统之间的解
Hive &mysql
Hive 由 Facebook 实现并开源，是基于 Hadoop 的一个数据仓库工具，可以将结构化的数据映射为一张数据库表，并提供 HQL(Hive SQL)查询功能，底层数据是存储在 HDFS 上。Hive的本质是将 SQL 语句转换为 MapReduce 任务运行，使不熟悉 MapReduce
Flink ClickHouse Sink：用于Apache Flink的高性能ClickHouse数据库连接器
Flink ClickHouse Sink：用于Apache Flink的高性能ClickHouse数据库连接器项目地址:https://gitcode.com/ivi-ru/flink-clickhouse-sink简介Apache Flink是一个用于分布式数据处理的开源框架。ClickHous
Flink 侧输出流（SideOutput）
ProcessFunction 的 side outputs 功能可以产生多条流，并且这些流的数据类型可以不一样。一个 side output 可以定义为 OutputTag[X]对象，X 是输出流的数据类型。process function 可以通过 Context 对象发射一个事件到一个或者多个
大数据风控平台：金融行业最佳实践
1.背景介绍大数据风控平台是金融行业中的一种应用，它利用大数据技术来分析和预测金融风险。在过去的几年里，随着数据的增长和技术的发展，大数据风控平台已经成为金融行业中最重要的技术之一。这篇文章将涵盖大数据风控平台的背景、核心概念、算法原理、代码实例以及未来发展趋势。1.1 金融风险的复杂性金融风险是金
数据仓库之Hologres
Hologres是阿里云推出的一种云原生的实时分析型数据仓库。它是基于开源项目Apache Hudi（Hadoop Upserts Deletes and Incrementals）进行扩展和优化的。Hologres提供了高性Hologres是阿里云推出的一种云原生的实时分析型数据仓库。它是基于开源
FlinkSql使用ES sink并指定主键，为什么数据还是会被覆盖？
源码基于flink 1.14.4根据官方文档中对自定义sink的描述，connector sink的的工作原理如下元数据的内容由create table语句所定义，通过的实例表示，该实例表示Catalog中未解析的元数据，包含可以在create table语句中表示的所有特征，框架将其解析为实例（一
【flink配置系列】FLink配置大全
所有配置都在`conf/flink-conf.yaml`中完成，这个文件应该是一个扁平的[YAML键值对](http://www.yaml.org/spec/1.2/spec.html)集合，格式为`key: value`。配置在Flink进程启动时被解析和评估。对配置文件的更改需要重新启动相关的进
大数据 - Doris系列《一》- Doris简介
Doris是一款开源的分布式OLAP（联机分析处理）数据库引擎，旨在支持高并发、大规模的数据查询和分析需求。本篇文章将深入介绍OLAP和OLTP的区别，明确它们在用户行为日志数据场景中的应用。我们将比较OLAP和OLTP在处理大规模数据时的性能和优势，并探讨开源OLAP引擎的选择。
kafka查看数据_Kafka 数据积压情况查看
消息发送到LeaderA之后会更新LEO的值，Follower1和Fllower2也会实时拉取LeaderA中的消息来更新自己，HW就表示A、B、C三者同时达到的日志位移。由于B、C拉取A消息之间延时问题，所有HW必然不会与Leader的LEO相等，即LEO>=HW。消息堆积量：消息中间件服务端中所
《大数据分析-数据仓库项目实战》学习笔记
文章部分内容参考《大数据分析-数据仓库项目实战》一书，仅供学习，喜欢可购买正版书籍，如有不妥请联系删除。
大数据分析设计-基于Hadoop运动项目推荐系统
2.2功能需求分析运动项目推荐系统的主要目的分为三个。首先：可以通过该系统可以很好的整合和发布体育项目的相关信息。以前通过传统的项目查询以及体验反馈的方式有个最大的问题就是信息查询、反馈方式繁琐，而且各种信息容易丢失，有了这样一个运动项目推荐系统，那么则可以很容易的把所有的运动项目信息都放到数据库中
【架构系列】RabbitMQ应用场景及在实际项目中如何搭建可靠的RabbitMQ架构体系
本文将深入探讨RabbitMQ的应用场景以及如何在实际项目中构建可靠的RabbitMQ架构体系。
hadoop 3 完全分布式+历史服务器
hadoop 3 完全分布式+历史服务器
Zookeeper，三个节点，详解（四）
所谓崩溃恢复，指的是当Zookeeper集群中leader产生宕机或者丢失的时候，整个集群不会停止服务而是会选举出一个新的leader继续对外提供服务崩溃恢复，可以很好的避免集群中出现单点故障(因为一个节点故障而导致整个集群崩溃)，实现集群的高可用在Zookeeper集群中，当leader产生丢失的
[2021]Zookeeper getAcl命令未授权访问漏洞概述与解决
今天在漏洞扫描的时候蹦出来一个zookeeper的漏洞问题，即使是非zookeeper的节点，或者是非集群内部节点，也可以通过nc扫描2181端口，获取极多的zk信息。关于漏洞的详细描述参考apache zookeeper官方概述：CVE-2018-8012: Apache ZooKeeper Qu
基于 RabbitMQ 实现 Eureka 服务平滑灰度发布
Slf4j@Override// 踢掉要下线的服务if (!} } }//... 根据需要做负载负载均衡规则} else {
Spring Boot集成Kafka：最佳实践与详细指南
本文详细介绍了如何在Spring Boot项目中集成Kafka，并通过最佳实践和代码示例来指导你。通过合理配置Kafka、使用KafkaTemplate发送消息、使用@KafkaListener接收消息以及处理错误和监控，你可以轻松地构建高效、可靠的消息处理系统。希望本文对你有所帮助！
【Linux】Linux——Centos7安装RabbitMQ
Linux下Centos7安装rabbtmq3.10
毕设项目 大数据电商用户行为分析及可视化(源码+论文)
今天学长向大家介绍一个机器视觉的毕设项目，大数据电商用户行为分析及可视化(源码+论文)毕业设计 基于大数据淘宝用户行为分析。
