开发交流QQ群: 941879291
SQLflow based on python development, support to Spark, as the underlying distributed computing engine, through a set of unified configuration file to complete the batch, flow calculation, the Rest service development.
主页:
结果页:SQLflow 基于python开发, 支持通过写sql的方式操作分布式集群, 运行spark, 机器学习, 深度学习, 分布式爬虫, 数据可视化。
git clone https://github.com/lqkweb/sqlflow.git
pip install -r requirements.txt
python manage.py
打开http://127.0.0.1:5000 就可以测试了。
【注意:1、下载apache spark文件配置manage.py中的SPARK_HOME路径。2、data.csv是放到sqlflow/data目录中】
测试1:
select * from A limit 3;
测试2:
select * from A limit 3 as B;
新开一个 http://127.0.0.1:5000 网页, 直接就可以查询数据表B了:
select * from B limit 2;
as B 相当于创建了一个 B 临时表。
一个简单的sql操作spark集群的demo,是不是很简单。