AWS CloudFormation テンプレートを使用してレプリケーションを開始する Neptune-to-OpenSearch

リージョンに固有の AWS CloudFormation スタックを起動する

以下の各 AWS CloudFormation テンプレートは、特定の AWS リージョンにストリームコンシューマーアプリケーションインスタンスを作成します。 AWS CloudFormation コンソールを使用して対応するスタックを起動するには、使用する AWS リージョンに応じて、次の表の起動スタックボタンのいずれかを選択します。

リージョン	ビュー	デザイナーで表示	起動する
米国東部 (バージニア北部)	表示	デザイナーで表示
米国東部 (オハイオ)	表示	デザイナーで表示
米国西部 (北カリフォルニア)	表示	デザイナーで表示
米国西部 (オレゴン)	表示	デザイナーで表示
カナダ (中部)	表示	デザイナーで表示
南米 (サンパウロ)	表示	デザイナーで表示
欧州 (ストックホルム)	表示	デザイナーで表示
欧州 (アイルランド)	表示	デザイナーで表示
欧州 (ロンドン)	表示	デザイナーで表示
欧州 (パリ)	表示	デザイナーで表示
欧州 (スペイン)	表示	デザイナーで表示
欧州 (フランクフルト)	表示	デザイナーで表示
中東 (バーレーン)	表示	デザイナーで表示
中東 (UAE）	表示	デザイナーで表示
イスラエル (テルアビブ)	表示	デザイナーで表示
アフリカ (ケープタウン)	表示	デザイナーで表示
アジアパシフィック (香港)	表示	デザイナーで表示
アジアパシフィック (東京)	表示	デザイナーで表示
アジアパシフィック (ソウル)	表示	デザイナーで表示
アジアパシフィック (シンガポール)	表示	デザイナーで表示
アジアパシフィック (ジャカルタ)	表示	デザイナーで表示
アジアパシフィック (ムンバイ)	表示	デザイナーで表示
中国 (北京)	表示	デザイナーで表示
中国 (寧夏)	表示	デザイナーで表示
AWS GovCloud （米国西部）	表示	デザイナーで表示
AWS GovCloud （米国東部）	表示	デザイナーで表示

[Create Stack (スタックの作成)] ページで、[Next (次へ)] を選択します。

作成する新しい OpenSearchスタックに関する詳細を追加する

[Specify Stack Details] (スタック詳細の指定) ページには、フルテキスト検索の設定を制御するために使用できるプロパティとパラメータがあります。

スタック名 – 作成する新しい AWS CloudFormation スタックの名前。通常は、デフォルト値、NeptuneStreamPoller を使用できます。

[Parameters (パラメータ)] で、以下を指定します。

ストリームコンシューマーが実行される VPC のネットワーク設定

• VPC– ポーリング Lambda 関数を実行する VPC の名前を指定します。

• List of Subnet IDs –  ネットワークインターフェースが確立されるサブネット。Neptune クラスターに対応するサブネットを追加します。

• List of Security Group Ids– ソース Neptune DB クラスターへの書き込みインバウンドアクセスを許可するIDsセキュリティグループの を提供します。

• List of Route Table Ids– これはVPC、Neptune に Amazon DynamoDB エンドポイントをまだ作成していない場合に必要です。サブネットIDsに関連付けられたルートテーブルのカンマ区切りリストを指定する必要があります。

• Require to create Dynamo DB VPC Endpoint –  デフォルトが true のブール値です。DynamoDB エンドポイントを で作成済みfalseである場合にのみ、 に変更する必要がありますVPC。

• Require to create Monitoring VPC Endpoint –  デフォルトが true のブール値です。モニタリングエンドポイントを で作成済みfalseである場合にのみ、 に変更する必要がありますVPC。

ストリームポーラー

• Application Name –  通常は、この設定をデフォルト (NeptuneStream) のままにしておくことができます。別の名前を使用する場合は、一意である必要があります。

• Memory size for Lambda Poller –  Lambda ポーラー関数で使用可能なメモリサイズを設定するために使用されます。デフォルト値は 2,048 メガバイトです。

• Lambda Runtime –  ストリームから項目を取得する Lambda 関数で使用される言語。これは python3.9 または java8 どちらにも設定できます。

• S3 Bucket having Lambda code artifacts –  別の S3 バケットからロードするカスタム Lambda ポーリング関数を使用している場合を除き、空白のままにしておきます。

• S3 Key corresponding to Lambda Code artifacts –  カスタム Lambda ポーリング関数を使用している場合を除き、この空白のままにしておきます。

• StartingCheckpoint — ストリームポーラーの開始チェックポイント。デフォルトは 0:0 であり、Neptune ストリームの始めから開始することを意味します。

• StreamPollerInitialState - ポーラーの初期状態。デフォルトは ENABLED であり、スタック全体の作成が完了するとすぐにストリームの複製が開始されることを意味します。

• Logging level for Lambda –  通常は、デフォルト値、INFO のままにしておきます。

• Managed Policies for Lambda Execution –  カスタム Lambda ポーリング関数を使用しない限り、通常は空白のままにしておきます。

• Stream Records Handler –  Neptune ストリーム内のレコードにカスタムハンドラを使用している場合を除き、通常は空白のままにしておきます。

• Maximum records Fetched from Stream –  このパラメータを使用して、パフォーマンスを調整できます。デフォルト (100) は、開始に適しています。最大許容値は 10,000 です。数値が大きいほど、ストリームからレコードを読み取るために必要なネットワークの呼び出しは少なくなりますが、レコードを処理するために必要なメモリは多くなります。

• Max wait time between two Polls (in Seconds) –  Neptune ストリームを ポーリングするために Lambda ポーラーが呼び出される頻度を決定します。連続ポーリングの場合は、この値を 0 に設定します。最大値は 3,600 秒 (60 分) です。グラフデータの変化速度に応じて、デフォルト値 (60 秒) は開始に適しています。

• Maximum Continuous polling period (in Seconds) –  Lambda ポーリング関数のタイムアウトを設定するために使用されます。これは、5 秒から 900 秒の間でなければなりません。デフォルト値 (600 秒) は、開始に適しています。

• Step Function Fallback Period– ポーラーを待機するユニット数 step-function-fallback-period。その後、ステップ関数が Amazon CloudWatch Events を介して呼び出され、障害から復旧します。デフォルト (5 分) は、開始に適しています。

• Step Function Fallback Period Unit –  直前の Step Function Fallback Period 測定に使用される時間単位 (分、時間、日)。通常は、デフォルト (分) で十分です。

• Data replication scope– ノードとエッジの両方をレプリケートするか、ノードのみをレプリケートするかを決定します OpenSearch （これは Gremlin エンジンデータにのみ適用されます）。一般的なケースであれば、まずはデフォルト値 (All) を使用することをお勧めします。

• Ignore OpenSearch missing document error– で欠落しているドキュメントエラーを無視 OpenSearch できるかどうかを決定するフラグ。ドキュメントの欠落エラーはまれに発生しますが、無視しない場合は手動による介入が必要になります。通常、デフォルト値 (True) は開始に適しています。

• Enable Non-String Indexing –  文字列の内容を持たないフィールドのインデックス作成を有効または無効にするフラグ。このフラグが に設定されている場合true、文字列以外のフィールドは でインデックス化され OpenSearch、 の場合は文字列フィールドfalseのみがインデックス化されます。デフォルト: true。

• Properties to exclude from being inserted into OpenSearch– OpenSearch インデックス作成から除外するプロパティまたは述語キーのカンマ区切りリスト。このCFNパラメータ値を空白のままにすると、すべてのプロパティキーにインデックスが付けられます。

• Datatypes to exclude from being inserted into OpenSearch– OpenSearch インデックス作成から除外するプロパティまたは述語データ型のカンマ区切りリスト。このCFNパラメータ値を空白のままにすると、安全に OpenSearch データ型に変換できるすべてのプロパティ値がインデックス化されます。

Neptune Stream

• Endpoint of source Neptune Stream –  (必須) これは次の 2 つの形式のいずれかになります。

  • https://your DB cluster:port/propertygraph/stream (またはそのエイリアス https://your DB cluster:port/pg/stream)。

  • https://your DB cluster:port/sparql/stream

• Neptune Query Engine– Gremlin または を選択しますSPARQL。

• Is IAM Auth Enabled?– Neptune DB クラスターがIAM認証を使用している場合は、このパラメータを に設定しますtrue。

• Neptune Cluster Resource Id– Neptune DB クラスターがIAM認証を使用している場合は、このパラメータをクラスターリソース ID に設定します。リソース ID はクラスター ID と同じではありません。正確には、28 文字の英数字が続く cluster- です。Neptune コンソールの [Cluster Details] (クラスターの詳細) で確認できます。

ターゲット OpenSearch クラスター

• Endpoint for OpenSearch service– (必須) OpenSearch サービスのエンドポイントを に指定しますVPC。

• Number of Shards for OpenSearch Index –  通常、デフォルト値 (5) は開始に適しています。

• Number of Replicas for OpenSearch Index –  通常、デフォルト値 (1) は開始に適しています。

• Geo Location Fields for Mapping –  位置情報フィールドを使用している場合は、ここにプロパティキーをリストします。

アラーム

• Require to create Cloud watch Alarm– 新しいスタックの CloudWatch アラームを作成するtrue場合は、これを に設定します。

• SNS Topic ARN for Cloudwatch Alarm Notifications – ARN CloudWatch アラーム通知を送信するSNSトピック (アラームが有効になっている場合にのみ必要）。

• Email for Alarm Notifications –  アラーム通知の送信先の E メールアドレス (アラームが有効な場合のみ必要)。

アラーム通知の送信先については、 SNS のみ、 E メールのみ、または SNSと E メールの両方を追加できます。

AWS CloudFormation テンプレートの実行

これで、次のように、Neptune ストリームコンシューマーアプリケーションインスタンスをプロビジョニングするプロセスを完了できます。

1. で AWS CloudFormation、スタックの詳細を指定ページで、次へ を選択します。

2. [Options(オプション)] ページで、[Next(次へ)] を選択します。

3. レビューページで、最初のチェックボックスをオンにして、 AWS CloudFormation がIAMリソースを作成することを確認します。新しいスタックの CAPABILITY_AUTO_EXPAND を確認する 2 つ目のチェックボックスをオンにします。

   注記

   CAPABILITY_AUTO_EXPAND は、スタックの作成時に事前の確認なしにマクロが展開されることを明示的に確認します。ユーザーは、処理されたテンプレートから変更セットを作成することが多いため、実際にスタックを作成する前にマクロによって行われた変更を確認できます。詳細については、 AWS CloudFormation APIリファレンスの AWS CloudFormation CreateStack「 APIオペレーション」を参照してください。

   次に [作成] を選択します。