このページ上

メインコンテンツをスキップする

このページは役に立ちましたか?

このページまたはコンテンツに、タイポ、ステップの省略、技術的エラーなどの問題が見つかった場合は、お知らせください。改善に役立たせていただきます。

Amazon Kinesisストリームにデータを書き込む

このセクションでは、Amazon EMRクラスターが稼働中であり、対応するクラスター接続メタデータがリポジトリーに作成済みであることを前提としています。また、Amazon Kinesisストリームが作成済みであることも前提としています。

Sparkフレームワークを使ってビッグデータストリーミングジョブを作成します。
この例では、Amazon Kinesisに書き込まれるデータは、tRowGeneratorコンポーネントで生成されます。
Amazon Kinesisストリームに書き込む前に、データをバイト配列としてシリアライズする必要があります。tWriteDelimitedFieldsコンポーネントを追加し、tRowGeneratorコンポーネントに接続します。
[Output type] (出力タイプ)をbyte[]に設定します。
データをKinesisストリームに書き込むには、tKinesisOutputコンポーネントを追加し、それにtWriteDelimitedFieldsコンポーネントを接続します。
Amazon認証情報を入力します。
Kinesisストリームにアクセスするには、ストリーム名と対応するエンドポイントURLを入力します。

適切なエンドポイントURLを取得するには、AWSリージョンとエンドポイントをご覧ください。
Kinesisストリームを作成した時に指定したように、シャードの数を指定します。