股票数据分析系统:
通过历史数据和线下实际情况相结合,将日期、股票代码、股票名称、股票当天开盘价、股票当天收盘价等等进行收集,并且对其进行剖析,得出分析结果。
1.通过 flume 对多数据源的数据进行实时采集,发送到 kafka 信息中间件中。
2.Kafka 把数据发送到 SparkStreaming,将实时接受的数据通过解析, Spark 函对数据进行清洗,加载。
3.将解析数据后上传到HDFS,通过SparkSQL将数据导入到Hive,而后通过SparkSQL操作Hive进行计算,而后将最终结果保存到MySQL。
进行数据分析,通过大数据对股票价格进行线上线下一手抓,通过这样的数据就能够判别出经济周期的所处阶段,对应所操作的股市,也就可以制定策略,调高盈利概率。