创建 Dask bag
您需要分析一些发布在 TripAdvisor 上的评论。您的同事已将这些评论整理为字符串列表。您想用 Dask 加速数据分析，因此首先需要把数据加载到一个 Dask bag 中。
本练习是课程的一部分
Python 中的 Dask 并行编程
练习说明
- 将
dask.bag子包以db的别名导入。 - 使用
from_sequence()函数把reviews_list转换为具有 3 个分区的 Dask bag。 - 使用该 bag 的
.take()方法打印该 Dask bag 中的一个元素。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Import the Dask bag subpackage as db
____
# Convert the list to a Dask bag
review_bag = db.____(____, ____=____)
# Print 1 element of the bag
print(____)