發(fā)簡(jiǎn)信
IP屬地：廣東
-
Python選基金(爬蟲+策略)
之前買基金都瞎買的，最近突然想可以用python來試試，綜合基金類型、持倉、收益率、基金經(jīng)理多維度綜合考慮，看看能不能幫忙選比較優(yōu)質(zhì)的基金出來。...
-
Flink解析kafka的json字段并利用Flink CEP實(shí)時(shí)監(jiān)控訂單數(shù)據(jù)寫入MySQL
上篇博客寫了Flink接入Kafka數(shù)據(jù)并實(shí)時(shí)寫入數(shù)據(jù)庫實(shí)時(shí)展示，這次利用Flink CEP進(jìn)行實(shí)時(shí)監(jiān)控。 整體架構(gòu)圖如下: 實(shí)現(xiàn)目標(biāo)如下： 1...
-
Flink實(shí)時(shí)讀取Kafka數(shù)據(jù)寫入Clickhouse并實(shí)時(shí)展示
整體架構(gòu)圖 工具 Flink 1.11.2 Scala 2.11 Tableau 2020.2 一、模擬發(fā)送數(shù)據(jù) 新建一個(gè)類KafkaProdu...
-
實(shí)時(shí)Lamda大數(shù)據(jù)平臺(tái)搭建Flume+Kafka+HDFS+SparkStreaming
整體架構(gòu)圖 一、python模擬生成日志 效果： 二、配置flume 這里配置兩個(gè)sink，一個(gè)發(fā)送到HDFS，一個(gè)發(fā)送到Kafka 三、配置K...
-
Flume跨服務(wù)器實(shí)時(shí)采集數(shù)據(jù)整體架構(gòu)如下圖，有兩臺(tái)服務(wù)器，在服務(wù)器之間傳輸一般用avro 或者Thrift比較多，這里選擇avro source和sink： 一、Flume...
-
Tableau實(shí)現(xiàn)累加多少天求和rolling_sum()比如求過去5天的累加和,在Excel里面很簡(jiǎn)單，公式一拖就可以 那么tableau該如何實(shí)現(xiàn)呢？ 這里用到了tableau的WINDOW_SUM...
-
BI自動(dòng)化之Python自動(dòng)查詢數(shù)據(jù)庫生成Excel并每天定時(shí)郵件發(fā)送
一、目的 1.每天自動(dòng)查詢SQL數(shù)據(jù) 2.生成Excel并作為附件郵件發(fā)送 3.每天定時(shí)自動(dòng)執(zhí)行 二、開發(fā)環(huán)境 1.Python3.5 2.SQ...
-
利用python深度分析微信朋友圈好友最近看了wxpy這個(gè)包，感覺還不錯(cuò)，分析一下微信的好友。 分析的目的： 1.看看好友的性別占比、地域分布 2.分析好友的個(gè)性簽名 3.對(duì)好友的簽...
-
python多進(jìn)程爬取上海房?jī)r(jià)并畫出熱力圖分析一、分析目的 1.探索上海市的房?jī)r(jià)區(qū)域分布 2.看看購房者都喜歡購買哪里的房子 二、數(shù)據(jù)采集 采集我愛我家上海區(qū)域的一萬兩千個(gè)小區(qū)的數(shù)據(jù)，采集的...