[JA] Translate gen-stage 1.1.1

ja/lessons/advanced/gen-stage.md

@@ -1,5 +1,5 @@
 ---
-version: 1.0.2
+version: 1.1.1
 title: GenStage
 ---
 
@@ -19,31 +19,41 @@ GenStageとは何でしょうか？ 公式ドキュメントによると「Elixi
 [A] -> [B] -> [C]
 ```
 
-この例では生産者(producer) `A` 、生産者-消費者(producer-consumer) `B` 、そして消費者(consumer) `C` という、3つのステージがあります。 `A` は `B` により消費される値を生産し、 `B` はなんらかの処理をしたのちに消費者 `C` によって受信される新しい値を返します。次のセクションで説明するようにステージの役割は重要です。
+この例では生産者(producer) `A` 、生産者-消費者(producer-consumer) `B` 、そして消費者(consumer) `C` という、3つのステージがあります。
+`A` は `B` により消費される値を生産し、 `B` はなんらかの処理をしたのちに消費者 `C` によって受信される新しい値を返します。次のセクションで説明するようにステージの役割は重要です。
 
 この例では、1対1の生産者対消費者となっていますが、どのステージにおいても、両方とも複数の生産者、複数の消費者を持つことが可能です。
 
 この概念をより詳しく説明するために、GenStageを使ってパイプラインを構築しますが、まずはじめにGenStageの各役割をもう少し深く掘り下げてみましょう。
 
 ## 消費者と生産者
 
-これまで見てきたように、ステージに与えられた役割は大切です。GenStageの仕様では以下の3つの役割があります。
+これまで見てきたように、ステージに与えられた役割は大切です。
+GenStageの仕様では以下の3つの役割があります。
 
-- `:producer` — 送り元。生産者は消費者からの催促を待ち、要求されたイベントに応じる。
+- `:producer` — 送り元。
+生産者は消費者からの催促を待ち、要求されたイベントに応じる。
 
-- `:producer_consumer` — 送り元と受け手の両方。生産者-消費者は、生産者からの要求イベントと同じように、他の消費者からの催促に応じる。
+- `:producer_consumer` — 送り元と受け手の両方。
+生産者-消費者は、生産者からの要求イベントと同じように、他の消費者からの催促に応じる。
 
-- `:consumer` — 受け手。消費者は、生産者に要求してデータを受け取る。
+- `:consumer` — 受け手。
+消費者は、生産者に要求してデータを受け取る。
 
-生産者が催促を **待っている** ことに注意してください。GenStageでは、消費者が上流の生産者に催促を送り、生産者から送られてくるデータを処理します。これによって、バックプレッシャーとして知られる仕組みが容易になります。バックプレッシャーというのは、消費者の処理がビジーの時に過剰なプレッシャーがかからないよう、生産者側にその責任を負わせる仕組みです。
+生産者が催促を **待っている** ことに注意してください。GenStageでは、消費者が上流の生産者に催促を送り、生産者から送られてくるデータを処理します。
+これによって、バックプレッシャーとして知られる仕組みが容易になります。
+バックプレッシャーというのは、消費者の処理がビジーの時に過剰なプレッシャーがかからないよう、生産者側にその責任を負わせる仕組みです。
 
 さて、GenStageの内部の役割についておさらいしたところで、実際のアプリケーションを作ってみましょう。
 
 ## はじめに
 
 この例では、数値を生成し、偶数をソートし、そして最後にそれらを出力するGenStageアプリケーションを構築します。
 
-このアプリケーションでは、3つのGenStageの役割を全て使います。「生産者」は、数を数えたり出力したりする責任があります。「生産者-消費者」は、偶数だけにフィルタリングし、下流から来る催促に応えます。最後に、数字を表示する「消費者」をつくります。
+このアプリケーションでは、3つのGenStageの役割を全て使います。
+「生産者」は、数を数えたり出力したりする責任があります。
+「生産者-消費者」は、偶数だけにフィルタリングし、下流から来る催促に応えます。
+最後に、数字を表示する「消費者」をつくります。
 
 まずはスーパーバイザーツリーを持つmixプロジェクトを作成しましょう。
 
@@ -57,7 +67,7 @@ $ cd genstage_example
 ```elixir
 defp deps do
   [
-    {:gen_stage, "~> 0.11"}
+    {:gen_stage, "~> 1.0.0"}
   ]
 end
 ```
@@ -72,10 +82,11 @@ $ mix do deps.get, compile
 
 ## 生産者
 
-GenStageアプリケーションの第一歩は、生産者の作成です。先ほど述べたように、一定の数のストリームを生成する生産者を作成する必要があります。という訳で早速、生産者のファイルを作成しましょう:
+GenStageアプリケーションの第一歩は、生産者の作成です。
+先ほど述べたように、一定の数のストリームを生成する生産者を作成する必要があります。
+という訳で早速、生産者のファイルを作成しましょう:
 
 ```shell
-$ mkdir lib/genstage_example
 $ touch lib/genstage_example/producer.ex
 ```
 
@@ -98,13 +109,18 @@ defmodule GenstageExample.Producer do
 end
 ```
 
-ここで着目すべき2つの重要な個所が `init/1` と `handle_demand/2` です。GenServerのところでやったように `init/1` で初期状態をセットしますが、もっと大切なのは自分自身に「生産者」とラベル付けすることです。GenStageは `init/1` 関数からの戻り値で自身のプロセスを分類します。
+ここで着目すべき2つの重要な個所が `init/1` と `handle_demand/2` です。
+GenServerのところでやったように `init/1` で初期状態をセットしますが、もっと大切なのは自分自身に「生産者」とラベル付けすることです。
+GenStageは `init/1` 関数からの戻り値で自身のプロセスを分類します。
 
-`handle_demand/2` 関数は生産者の大部分がある場所ですが、この関数は全てのGenStage生産者が実装しなければなりません。ここで消費者によって催促された数のセットを返し、カウンターを増やします。消費者からの催促は、上記のコードでは `demand` となっていますが、これは処理可能なイベントの数に対応する整数として表されています（デフォルト値は1000です）。
+`handle_demand/2` 関数は生産者の大部分がある場所ですが、この関数は全てのGenStage生産者が実装しなければなりません。
+ここで消費者によって催促された数のセットを返し、カウンターを増やします。
+消費者からの催促は、上記のコードでは `demand` となっていますが、これは処理可能なイベントの数に対応する整数として表されています（デフォルト値は1000です）。
 
 ## 生産者-消費者
 
-数を生成する生産者ができたので、今度は生産者-消費者に移りましょう。生産者に数を催促し、数をフィルターして偶数のみに絞り、消費者からの催促に応えたいと思います。
+数を生成する生産者ができたので、今度は生産者-消費者に移りましょう。
+生産者に数を催促し、数をフィルターして偶数のみに絞り、消費者からの催促に応えたいと思います。
 
 ```shell
 $ touch lib/genstage_example/producer_consumer.ex
@@ -118,7 +134,7 @@ defmodule GenstageExample.ProducerConsumer do
 
   require Integer
 
-  def start_link do
+  def start_link(_initial) do
     GenStage.start_link(__MODULE__, :state_doesnt_matter, name: __MODULE__)
   end
 
@@ -136,13 +152,18 @@ defmodule GenstageExample.ProducerConsumer do
 end
 ```
 
-生産者-消費者に `init/1` の中の新しいオプションと新しい関数 `handle_events/3` を導入したことに気づかれたかもしれません。ここでは `subscribe_to` オプションを用いて、ある特定の生産者と通信することをGenStageに指示しています。
+生産者-消費者に `init/1` の中の新しいオプションと新しい関数 `handle_events/3` を導入したことに気づかれたかもしれません。
+ここでは `subscribe_to` オプションを用いて、ある特定の生産者と通信することをGenStageに指示しています。
 
-`handle_events/3` 関数は、入ってくるイベントを受取って処理し変換した値の集合を返す場所です。ここからもわかるように、消費者はほとんど同じ方法で実装されますが、重要な違いは、 `handle_events/3` 関数の戻り値とその使用方法です。プロセスにproducer_consumerとラベル付けすると、タプルの第2引数（ここでは `numbers`）が下流の消費者からの要求を満たすために使われます。消費者側ではこの値は破棄されます。
+`handle_events/3` 関数は、入ってくるイベントを受取って処理し変換した値の集合を返す場所です。
+ここからもわかるように、消費者はほとんど同じ方法で実装されますが、重要な違いは、 `handle_events/3` 関数の戻り値とその使用方法です。
+プロセスにproducer_consumerとラベル付けすると、タプルの第2引数（ここでは `numbers`）が下流の消費者からの要求を満たすために使われます。
+消費者側ではこの値は破棄されます。
 
 ## 消費者
 
-最後に消費者があります。でははじめましょう:
+最後に消費者があります。
+でははじめましょう:
 
 ```shell
 $ touch lib/genstage_example/consumer.ex
@@ -154,7 +175,7 @@ $ touch lib/genstage_example/consumer.ex
 defmodule GenstageExample.Consumer do
   use GenStage
 
-  def start_link do
+  def start_link(_initial) do
     GenStage.start_link(__MODULE__, :state_doesnt_matter)
   end
 
@@ -186,9 +207,9 @@ def start(_type, _args) do
   import Supervisor.Spec, warn: false
 
   children = [
-    worker(GenstageExample.Producer, [0]),
-    worker(GenstageExample.ProducerConsumer, []),
-    worker(GenstageExample.Consumer, [])
+    {GenstageExample.Producer, 0},
+    {GenstageExample.ProducerConsumer, []},
+    {GenstageExample.Consumer, []},
   ]
 
   opts = [strategy: :one_for_one, name: GenstageExample.Supervisor]
@@ -200,6 +221,7 @@ end
 
 ```shell
 $ mix run --no-halt
+{#PID<0.109.0>, 0, :state_doesnt_matter}
 {#PID<0.109.0>, 2, :state_doesnt_matter}
 {#PID<0.109.0>, 4, :state_doesnt_matter}
 {#PID<0.109.0>, 6, :state_doesnt_matter}
@@ -211,31 +233,40 @@ $ mix run --no-halt
 
 できました！ アプリケーションが偶数だけを出力するのを期待していましたが、こんなにも **素早く** 出力しています。
 
-ここに処理パイプラインがあります。生産者は数字を出力し、生産者-消費者は奇数を破棄して、そして消費者はそれらの数を表示するというフローを続けています。
+ここに処理パイプラインがあります。
+生産者は数字を出力し、生産者-消費者は奇数を破棄して、そして消費者はそれらの数を表示するというフローを続けています。
 
 ## 複数の生産者もしくは消費者
 
-イントロダクションで言及したように、1つ以上の生産者、または、消費者を持つことができます。少し見てみましょう。
+イントロダクションで言及したように、1つ以上の生産者、または、消費者を持つことができます。
+少し見てみましょう。
 
-サンプルから `IO.inspect/1` の出力を調べると、各々のイベントは単一のPIDによって処理されていることがわかります。 `lib/genstage_example/application.ex` を修正して複数のワーカーが動くように少し調整してみましょう。
+サンプルから `IO.inspect/1` の出力を調べると、各々のイベントは単一のPIDによって処理されていることがわかります。
+`lib/genstage_example/application.ex` を修正して複数のワーカーが動くように少し調整してみましょう。
 
 ```elixir
 children = [
-  worker(GenstageExample.Producer, [0]),
-  worker(GenstageExample.ProducerConsumer, []),
-  worker(GenstageExample.Consumer, [], id: 1),
-  worker(GenstageExample.Consumer, [], id: 2)
+  {GenstageExample.Producer, 0},
+  {GenstageExample.ProducerConsumer, []},
+  %{
+    id: 1,
+    start: {GenstageExample.Consumer, :start_link, [[]]}
+  },
+  %{
+    id: 2,
+    start: {GenstageExample.Consumer, :start_link, [[]]}
+  },
 ]
 ```
 
 ここで2つの消費者を設定してアプリケーションを実行するとどうなるか、見てみましょう。
 
 ```shell
 $ mix run --no-halt
+{#PID<0.120.0>, 0, :state_doesnt_matter}
 {#PID<0.120.0>, 2, :state_doesnt_matter}
-{#PID<0.121.0>, 4, :state_doesnt_matter}
+{#PID<0.120.0>, 4, :state_doesnt_matter}
 {#PID<0.120.0>, 6, :state_doesnt_matter}
-{#PID<0.120.0>, 8, :state_doesnt_matter}
 ...
 {#PID<0.120.0>, 86478, :state_doesnt_matter}
 {#PID<0.121.0>, 87338, :state_doesnt_matter}
@@ -249,7 +280,9 @@ $ mix run --no-halt
 
 さてこれまでにGenStageについて学習し最初のサンプルアプリケーションを構築してきましたが、GenStageの **実際の** ユースケースはどのようなものがあるのでしょうか。
 
-- データ変換パイプライン - 生産者は、単純な数値ジェネレータである必要はありません。データベースや、Apache Kafkaのような別のデータソースからイベントを生成することもできます。生産者-消費者と消費者を組み合わせれば、それらが利用可能になった時に、メトリクスを処理したりソートしたりカタログ化したり保存したりすることができます。
+- データ変換パイプライン - 生産者は、単純な数値ジェネレータである必要はありません。
+データベースや、Apache Kafkaのような別のデータソースからイベントを生成することもできます。
+生産者-消費者と消費者を組み合わせれば、それらが利用可能になった時に、メトリクスを処理したりソートしたりカタログ化したり保存したりすることができます。
 
 - 処理キュー - イベントはどんなものでもありえますが、一連の消費者によって実行される、まとまった処理を生成することができます。