翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

# ストリーミングステップの送信
<a name="CLI_CreateStreaming"></a>

このセクションでは、クラスターにストリーミングステップを送信するための基本について説明します。ストリーミングアプリケーションは、標準入力から入力を読み取って、スクリプトまたは実行可能ファイル (マッパーと呼ばれます) を各入力に対して実行します。各入力の結果は、ローカル（通常は Hadoop Distributed File System（HDFS）パーティション）に保存されます。すべての入力がマッパーによって処理されたら、そのマッパーの結果は、2 つ目のスクリプトまたは実行可能ファイル (リデューサーと呼ばれます) によって処理されます。リデューサーの結果は標準出力に送信されます。一連のストリーミングステップをつなげて、あるステップの出力を別のステップの入力にすることができます。

マッパーとリデューサーはそれぞれファイルとして参照できます。また、Java クラスを指定することもできます。マッパーおよびリデューサーは、Ruby、Perl、Python、PHP、Bash など、サポートされている任意の言語で実装できます。

## コンソールを使用したストリーミングステップの送信
<a name="emr-dev-create-stream-console"></a>

この例では、Amazon EMR コンソールを使用し、実行中のクラスターにストリーミングステップを送信する方法について説明します。

**ストリーミングステップを送信するには**

1. [https://console.aws.amazon.com/emr](https://console.aws.amazon.com/emr/) で Amazon EMR コンソールを開きます。

1. [**Cluster List (クラスターリスト)**] で、クラスターの名前を選択します。

1. [**Steps (ステップ)**] セクションまでスクロールして展開し、[**Add step (ステップの追加)**] を選択します。

1. [**Add Step**] ダイアログボックスで、次のようにします。
   + [**Step type**] は [**Streaming program**] を選択します。
   + [**Name**] では、デフォルト名（Streaming program）を使用するか、または新しい名前を入力します。
   + [**Mapper (マッパー)**] では、Hadoop のマッパークラスの場所、または Python プログラムなどのマッパー実行ファイルが存在する S3 バケットを入力するか参照します。パスの値は *BucketName*/*path*/*MapperExecutable* という書式で指定する必要があります。
   + [**Reducer (リデューサー)**] では、Hadoop のリデューサークラスの場所、または Python プログラムなどのリデューサー実行ファイルが存在する S3 バケットを入力するか参照します。パスの値は *BucketName*/*path*/*MapperExecutable* という書式で指定する必要があります。Amazon EMR は、特別な *aggregate* キーワードをサポートしています。詳細については、Hadoop が提供する Aggregate ライブラリを参照してください。
   + [**Input S3 location**] では、入力データの場所を入力または参照します。
   + **[Output S3 location]** (S3 の場所の出力) で、Amazon S3 出力バケットの名前を入力するか、参照します。
   + [**Arguments (引数)**] は、フィールドを空のままにします。
   + [**Action on failure (失敗時の操作)**] では、デフォルトのオプション ([**Continue (続行)**]) を使用します。

1. **[Add]** (追加) を選択します。ステップは、[Pending] というステータスでコンソールに表示されます。

1. ステップが実行されると、ステータスは [Pending (保留中)] から [Running (実行中)]、[Running (実行中)] から [完了済み] に変更されます。ステータスを更新するには、[Actions] 列の上にある [**Refresh**] アイコンを選択します。

## AWS CLI
<a name="emr-dev-create-stream-cli"></a>

これらの例は、 AWS CLI を使用してクラスターを作成し、ストリーミングステップを送信する方法を示しています。

**を使用してクラスターを作成し、ストリーミングステップを送信するには AWS CLI**
+ を使用してクラスターを作成し、ストリーミングステップを送信するには AWS CLI、次のコマンドを入力し、*myKey* を EC2 キーペアの名前に置き換えます。`--files` の引数はスクリプトの場所の Amazon S3 パスで、`-mapper` および `-reducer` の引数はそれぞれのスクリプトファイルの名前にする必要があります。

  ```
  aws emr create-cluster --name "Test cluster" --release-label emr-7.12.0 --applications Name=Hue Name=Hive Name=Pig --use-default-roles \
  --ec2-attributes KeyName=myKey --instance-type m5.xlarge --instance-count 3 \
  --steps Type=STREAMING,Name="Streaming Program",ActionOnFailure=CONTINUE,Args=[--files,pathtoscripts,-mapper,mapperscript,-reducer,reducerscript,aggregate,-input,pathtoinputdata,-output,pathtooutputbucket]
  ```
**注記**  
読みやすくするために、Linux 行連続文字 (\$1) が含まれています。Linux コマンドでは、これらは削除することも、使用することもできます。Windows の場合、削除するか、キャレット (^) に置き換えてください。

  `--instance-groups` パラメータを使用せずにインスタンス数を指定すると、1 つのマスターノードが起動され、残りのインスタンスはコアノードとして起動されます。すべてのノードで、コマンドで指定したインスタンスタイプが使用されます。
**注記**  
以前にデフォルトの Amazon EMR サービスロールと EC2 インスタンスプロファイルを作成していない場合は、「aws `emr create-default-roles`」と入力してそれらを作成してから、`create-cluster` サブコマンドを入力します。

  での Amazon EMR コマンドの使用の詳細については AWS CLI、「」を参照してください[https://docs.aws.amazon.com/cli/latest/reference/emr](https://docs.aws.amazon.com/cli/latest/reference/emr)。