Dask bag を作成する
TripAdvisor に投稿されたレビューを分析する担当になりました。同僚が、レビューを文字列のリストとして用意してくれています。Dask を使ってデータ分析を高速化したいので、まずはこのデータを Dask bag に読み込みます。
この演習はコースの一部です
Pythonで学ぶDaskによる並列プログラミング
演習の手順
dask.bagサブパッケージをdbとしてインポートします。from_sequence()関数を使って、reviews_listを 3 パーティションの Dask bag に変換します。- bag の
.take()メソッドを使って、Dask bag から要素を 1 件だけ表示します。
実践的なインタラクティブ演習
このサンプルコードを完成させて、この演習に挑戦してみましょう。
# Import the Dask bag subpackage as db
____
# Convert the list to a Dask bag
review_bag = db.____(____, ____=____)
# Print 1 element of the bag
print(____)