• 欢迎访问搞代码网站,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站!
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏搞代码吧

关于python:去安一个Python大数据分析神器效果如何

python 搞代码 3年前 (2022-02-20) 14次浏览 已收录 0个评论

对于Pandas运行速度的晋升办法,之前曾经介绍过很多回了,外面常常提及Dask,很多敌人没接触过可能不是很理解,明天小编就举荐一下这个神器。

1、Dask是很么?

Pandas和Numpy大家都不生疏了,代码运行后数据都加载到RAM中,如果数据集特地大,咱们就会看到内存飙升。但有时要解决的数据并不适宜RAM,这时候Dask体现到了。

Dask是开源收费。它是与其余社区我的项目(如Numpy,Pandas和Scikit-Learn)协调开发。

官网:https://dask.org/

Dask反对Pandas的DataFrame和NumpyArray的数据结构,并且既可在本地计算机上运行,也能够扩大到在集群上运行。

基本上,只有编写一次代码,应用一般的Pythonic语法,就可在本地运行或部署到多节点集群上。这自身就是牛逼的性能了,但这还不是最牛逼。

我感觉Dask的最牛逼的性能是:它兼容大部分咱们曾经在用的工具,并且只需改变大量的代码,就能够利用本人笔记本电脑上已有的解决能力并行运行代码。而并行处理数据就意味着更少的执行工夫,更少的等待时间和更多的剖析工夫。

上面这个就是Dask进行数据处理的大抵流程。

2、Dask反对哪些工具?

这一点也是我比拟看中的,因为Dask能够与Python数据处理和建模的库包兼容,沿用库包的API,这对于Python使用者来说学习老本是极低的。而像Hadoop、Spark这种大数据处理是有很高的学习门槛和工夫老本。

目前,Dask可反对pandas、Numpy、Sklearn、XGBoost、XArray、RAPIDS等等,光是这几项我感觉就足够用了,至多对于罕用的数据处理、建模剖析是齐全笼罩得掉。

3、装置Dask

能够应用 conda 或者 pip,或从源代码装置dask 。

因为dask有很多依赖,所以为了疾速装置也可用上面代码,将装置运行Dask所需的起码依赖关系集。

再有就是通过源来装置。

4、如何应用Dask?

Numpy、pandas

Dask引入了3个并行汇合,它们能够存储大于RAM的数据,这些汇合有DataFrame、Bags、Arrays。这些汇合类型中的每一个都可能应用在RAM和硬盘之间分区的数据,以及散布在群集中多个节点上的数据。

Dask的应用是十分清晰的,如果你应用NumPy数组,就从Dask数组开始,如果你应用Pandas DataFrame,就从Dask DataFrame开始,依此类推。

这些高级接口在稍微变动的状况下复制了标准接口。对于原始我的项目中的大部分API,这些接口会主动为咱们并行处理较大的数据集,实现上不是很简单,对照Dask的doc文档即可一步步实现。

Delayed

上面说一下Dask的 Delay 性能,十分弱小。

Dask.delayed是一种并行化现有代码的简略而弱小的办法。之所以被叫做delayed是因为,它没有立刻计算出后果,而是将要作为工作计算的后果记录在一个图形中,稍后将在并行硬件上运行。

有时问题用已有的dask.array或dask.dataframe可能都不适宜,在这些状况下,咱们能够应用更简略的dask.delayed界面并行化自定义算法。例如上面这个例子展现了这个算法。

下面代码在单个线程中按程序运行。然而,咱们看到其中很多能够并行执行。Dask delayed函数可润饰inc、double这些函数,以便它们可提早运行,而不是立刻执行函数,它将函数及其参数放入计算工作图中。

咱们简略批改代码,用delayed函数包装一下。

代码运行后inc、double、add和sum都还没有产生,而是生成一个计算的工作图交给了total。而后咱们用visualizatize看下工作图。

上图显著看到了并行的可能性,所以毫不犹豫,应用compute进行并行计算,这时才实现了计算。

因为数据集较小无奈比拟工夫,这里只介绍下应用办法,具体可本人入手实际下。

机器学习Sklearn

对于机器学习的并行化执行,因为内容较多,东哥会在另一篇文章开展。这里简略说下一下dask-learn。

dask-learn我的项目是与Sklearn开发人员合作实现的。当初可实现并行化有Scikit-learn的Pipeline、GridsearchCV和RandomSearchCV以及这些的变体,它们能够更好地解决嵌套的并行操作。

因而,如果咱们将sklearn替换为dklearn,那么速度将会晋升很多。

上面是一个应用Pipeline的示例,其中利用了PCA和逻辑回归。

得出的后果是:sklearn会在40秒钟左右执行此计算,而dask-learn替代品大概须要10秒钟。

另外,如果增加以下代码能够连贯到集群,通过Client能够展现整个计算过程的dashboard,由Bokeh实现。

5、总结

以上简略的介绍Dask的,Dask的性能是十分弱小的,且阐明文档也十分全,既有示例又有解释。感兴趣的敌人,下期小七有更美的文章等你来浏览


搞代码网(gaodaima.com)提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected],我们会在看到邮件的第一时间内为您处理,或直接联系QQ:872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:关于python:去安一个Python大数据分析神器效果如何

喜欢 (0)
[搞代码]
分享 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址