之前买基金都瞎买的,最近突然想可以用python来试试,综合基金类型、持仓、收益率、基金经理多维度综合考虑,看看能不能帮忙选比较优质的基金出来。...
上篇博客写了Flink接入Kafka数据并实时写入数据库实时展示,这次利用Flink CEP进行实时监控。 整体架构图如下: 实现目标如下: 1...
整体架构图 工具 Flink 1.11.2 Scala 2.11 Tableau 2020.2 一、模拟发送数据 新建一个类KafkaProdu...
整体架构图 一、python模拟生成日志 效果: 二、配置flume 这里配置两个sink,一个发送到HDFS,一个发送到Kafka 三、配置K...
整体架构如下图,有两台服务器,在服务器之间传输一般用avro 或者Thrift比较多,这里选择avro source和sink: 一、Flume...
比如求过去5天的累加和,在Excel里面很简单,公式一拖就可以 那么tableau该如何实现呢? 这里用到了tableau的WINDOW_SUM...
一、目的 1.每天自动查询SQL数据 2.生成Excel并作为附件邮件发送 3.每天定时自动执行 二、开发环境 1.Python3.5 2.SQ...
最近看了wxpy这个包,感觉还不错,分析一下微信的好友。 分析的目的: 1.看看好友的性别占比、地域分布 2.分析好友的个性签名 3.对好友的签...
一、分析目的 1.探索上海市的房价区域分布 2.看看购房者都喜欢购买哪里的房子 二、数据采集 采集我爱我家上海区域的一万两千个小区的数据,采集的...