翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
AWS CloudFormation テンプレートを使用して Neptune-to-OpenSearchレプリケーションを開始する
リージョンに固有の AWS CloudFormation スタックを起動する
以下の各 AWS CloudFormation テンプレートは、特定の AWS リージョンにストリームコンシューマーアプリケーションインスタンスを作成します。 AWS CloudFormation コンソールを使用して対応するスタックを起動するには、使用する AWS リージョンに応じて、次の表の起動スタックボタンのいずれかを選択します。
| リージョン | ビュー | デザイナーで表示 | 起動する |
|---|---|---|---|
| 米国東部 (バージニア北部) | 表示 |
デザイナーで表示 |
|
| 米国東部 (オハイオ) | 表示 |
デザイナーで表示 |
|
| 米国西部 (北カリフォルニア) | 表示 |
デザイナーで表示 |
|
| 米国西部 (オレゴン) | 表示 |
デザイナーで表示 |
|
| カナダ (中部) | 表示 |
デザイナーで表示 |
|
| 南米 (サンパウロ) | 表示 |
デザイナーで表示 |
|
| 欧州 (ストックホルム) | 表示 |
デザイナーで表示 |
|
| 欧州 (アイルランド) | 表示 |
デザイナーで表示 |
|
| 欧州 (ロンドン) | 表示 |
デザイナーで表示 |
|
| 欧州 (パリ) | 表示 |
デザイナーで表示 |
|
| 欧州 (スペイン) | 表示 |
デザイナーで表示 |
|
| 欧州 (フランクフルト) | 表示 |
デザイナーで表示 |
|
| 中東 (バーレーン) | 表示 |
デザイナーで表示 |
|
| 中東 (アラブ首長国連邦) | 表示 |
デザイナーで表示 |
|
| イスラエル (テルアビブ) | 表示 |
デザイナーで表示 |
|
| アフリカ (ケープタウン) | 表示 |
デザイナーで表示 |
|
| アジアパシフィック (香港) | 表示 |
デザイナーで表示 |
|
| アジアパシフィック (東京) | 表示 |
デザイナーで表示 |
|
| アジアパシフィック (ソウル) | 表示 |
デザイナーで表示 |
|
| アジアパシフィック (シンガポール) | 表示 |
デザイナーで表示 |
|
| アジアパシフィック (ジャカルタ) | 表示 |
デザイナーで表示 |
|
| アジアパシフィック (ムンバイ) | 表示 |
デザイナーで表示 |
|
| 中国 (北京) | 表示 |
デザイナーで表示 |
|
| 中国 (寧夏) | 表示 |
デザイナーで表示 |
|
| AWS GovCloud (米国西部) | 表示 |
デザイナーで表示 |
|
| AWS GovCloud (米国東部) | 表示 |
デザイナーで表示 |
|
[Create Stack (スタックの作成)] ページで、[Next (次へ)] を選択します。
作成する新しい OpenSearch スタックに関する詳細を追加する
[Specify Stack Details] (スタック詳細の指定) ページには、フルテキスト検索の設定を制御するために使用できるプロパティとパラメータがあります。
スタック名 – 作成する新しい AWS CloudFormation スタックの名前。通常は、デフォルト値、NeptuneStreamPoller を使用できます。
[Parameters (パラメータ)] で、以下を指定します。
Streams コンシューマーが実行される VPC のネットワーク設定
VPC– ポーリング Lambda 関数を実行する VPC の名前を指定します。List of Subnet IDs– ネットワークインターフェースが確立されるサブネット。Neptune クラスターに対応するサブネットを追加します。List of Security Group Ids– ソース Neptune DB クラスターへの書き込みインバウンドアクセスを許可するセキュリティグループの ID を指定します。List of Route Table Ids– これは、Neptune VPC に Amazon DynamoDB エンドポイントを作成するために必要です (まだエンドポイントを持っていない場合)。サブネットに関連付けられたルートテーブル ID のコンマ区切りリストを指定する必要があります。Require to create Dynamo DB VPC Endpoint– デフォルトがtrueのブール値です。この値をfalseに変更する必要があるのは、VPC に作成済みの DynamoDB エンドポイントがある場合のみです。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– ポーラーが待機するステップ関数フォールバック期間単位の数。この数に達すると、ステップ関数が 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/streamhttps://)。your DB cluster:port/pg/streamhttps://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– (必須) VPC で OpenSearch サービスのエンドポイントを提供します。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- CloudWatch アラーム通知の送信先の SNS トピック ARN (アラームが有効な場合のみ必要)。Email for Alarm Notifications– アラーム通知の送信先の E メールアドレス (アラームが有効な場合のみ必要)。
アラーム通知の宛先には、SNS のみ、E メールのみ、または SNS と E メールの両方を追加できます。
AWS CloudFormation テンプレートを実行する
これで、次のように、Neptune ストリームコンシューマーアプリケーションインスタンスをプロビジョニングするプロセスを完了できます。
スタックの詳細 AWS CloudFormationの指定ページで、次へを選択します。
[Options(オプション)] ページで、[Next(次へ)] を選択します。
-
[確認] ページで、 AWS CloudFormation によって IAM リソースが作成されることを確認する最初のチェックボックスをオンにします。新しいスタックの
CAPABILITY_AUTO_EXPANDを確認する 2 つ目のチェックボックスをオンにします。注記
CAPABILITY_AUTO_EXPANDは、スタックの作成時に事前の確認なしにマクロが展開されることを明示的に確認します。ユーザーは、処理されたテンプレートから変更セットを作成することが多いため、実際にスタックを作成する前にマクロによって行われた変更を確認できます。詳細については、 API AWS CloudFormation リファレンスの AWS CloudFormation CreateStack API オペレーション」を参照してください。次に [作成] を選択します。