タスクグラフをプロットする
あなたは自社の支出記録を分析しようとしています。マネージャーは、各月の支出が総額に対してどのくらいの割合かを見たいと考えています。ただし多くのファイルで同じ処理を実行する必要があるため、スレッドやプロセスで高速化できるように、遅延計算を設定しておくとよいでしょう。どちらのタスクスケジューリング方式がこの計算に適しているかを検討するため、タスクグラフを可視化したいと考えています。
2か月分の合計支出は、month_1_costs と month_2_costs という遅延オブジェクトとして用意されています。dask もインポート済みです。
この演習はコースの一部です
Pythonで学ぶDaskによる並列プログラミング
演習の手順
- 2か月分から総支出を計算します。
- 総額に対して1か月目に支出した割合を求めます。
- 総額に対して2か月目に支出した割合を求めます。
month_1_fractionとmonth_2_fractionを計算するための統合タスクグラフを可視化します。
実践的なインタラクティブ演習
このサンプルコードを完成させて、この演習に挑戦してみましょう。
# Add the two delayed month costs
total_costs = ____
# Calculate the fraction of total cost from month 1
month_1_fraction = ____
# Calculate the fraction of total cost from month 2
month_2_fraction = ____
# Plot the joint task graph used to calculate the fractions
____