翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。 # Amazon Neptune から OpenSearch へのレプリケーション Amazon Neptune は、Amazon OpenSearch Service (OpenSearch Service) を使用して Gremlin および SPARQL クエリでフルテキスト検索をサポートします。 AWS CloudFormation スタックを使用して、OpenSearch Service ドメインを Neptune にリンクできます。 CloudFormation テンプレートは、Neptune-to-OpenSearchレプリケーションを提供するストリームコンシューマーアプリケーションインスタンスを作成します。 開始する前に、ソースとして機能するストリームを有効にした既存の Neptune DB クラスターと、レプリケーションターゲットとして機能する OpenSearch Service ドメインが必要です。 Neptune DB クラスターが配置されている VPC に Lambda がアクセスできる既存のターゲット OpenSearch Service ドメインが既に存在する場合、テンプレートはそのターゲットドメインを使用できます。それ以外の場合は、新しいものを作成する必要があります。 **注記** 作成する OpenSearch クラスターと Lambda 関数は、Neptune DB クラスターと同じ VPC に配置する必要があり、OpenSearch クラスターは VPC モード (インターネットモードではなく) で設定する必要があります。 OpenSearch Service で使用するには、新しく作成した Neptune インスタンスを使用することをお勧めします。既にデータがある既存のインスタンスを使用する場合は、クエリを行う前に OpenSearch Service データ同期を実行する必要があります。そうしないと、データの不整合が生じる可能性があります。この GitHub プロジェクトでは、同期を実行する方法の例を [Export Neptune to OpenSearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch) (https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch) に用意しています。 **重要** Amazon OpenSearch Service と統合する場合、Neptune は Elasticsearch バージョン 7.1 以降を必要とし、OpenSearch 2.3、2.5、および将来の互換性のあるバージョンの Opensearch でも動作します。 **注記** [エンジンリリース 1.3.0.0](engine-releases-1.3.0.0.md) 以降、Amazon Neptune は Gremlin クエリと SPARQL クエリでのフルテキスト検索において [Amazon OpenSearch Service サーバーレス](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/serverless.html)の使用をサポートしています。 **Topics** + [AWS CloudFormation テンプレートを使用して Neptune-to-OpenSearchレプリケーションを開始する](full-text-search-cfn-create.md) + [既存の Neptune データベースでフルテキスト検索を有効にする](full-text-search-cfn-enabling.md) + [ストリームポーラーの更新](full-text-search-cfn-update-poller.md) + [ストリームポーラープロセスの無効化と再有効化](full-text-search-using-pausing-poller.md) # AWS CloudFormation テンプレートを使用して Neptune-to-OpenSearchレプリケーションを開始する ## リージョンに固有の CloudFormation スタックを起動する 以下の各 CloudFormation テンプレートは、特定の AWS リージョンにストリームコンシューマーアプリケーションインスタンスを作成します。 CloudFormation コンソールを使用して対応するスタックを起動するには、使用する AWS リージョンに応じて、次の表の**起動スタック**ボタンのいずれかを選択します。 | リージョン | 表示 | デザイナーで表示 | 起動する | | --- | --- | --- | --- | | 米国東部 (バージニア北部) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=us-east-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=us-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=us-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 米国東部 (オハイオ) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=us-east-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=us-east-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=us-east-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 米国西部 (北カリフォルニア) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=us-west-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=us-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=us-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 米国西部 (オレゴン) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=us-west-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=us-west-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=us-west-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | カナダ (中部) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=us-west-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ca-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ca-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 南米 (サンパウロ) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=sa-east-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=sa-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=sa-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 欧州 (ストックホルム) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-north-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-north-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-north-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 欧州 (アイルランド) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-west-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 欧州 (ロンドン) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-west-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-west-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-west-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 欧州 (パリ) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-west-3&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-west-3#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-west-3#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 欧州 (スペイン) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-south-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-south-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-south-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 欧州 (フランクフルト) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=eu-central-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=eu-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=eu-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 中東 (バーレーン) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=me-south-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=me-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=me-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 中東 (アラブ首長国連邦) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=me-central-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=me-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=me-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | イスラエル (テルアビブ) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=il-central-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=il-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=il-central-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | アフリカ (ケープタウン) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=af-south-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=af-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=af-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | アジアパシフィック (香港) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-east-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | アジアパシフィック (東京) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-northeast-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-northeast-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-northeast-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | アジアパシフィック (ソウル) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-northeast-2&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-northeast-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-northeast-2#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | アジアパシフィック (シンガポール) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-southeast-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-southeast-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-southeast-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | アジアパシフィック (ジャカルタ) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-southeast-3&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-southeast-3#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-southeast-3#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | アジアパシフィック (ムンバイ) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.aws.amazon.com/cloudformation/designer/home?region=ap-south-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.aws.amazon.com/cloudformation/home?region=ap-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.aws.amazon.com/cloudformation/home?region=ap-south-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 中国 (北京) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.amazonaws.cn/cloudformation/designer/home?region=cn-north-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.amazonaws.cn/cloudformation/home?region=cn-north-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.amazonaws.cn/cloudformation/home?region=cn-north-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | 中国 (寧夏) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.amazonaws.cn/cloudformation/designer/home?region=cn-northwest-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.amazonaws.cn/cloudformation/home?region=cn-northwest-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.amazonaws.cn/cloudformation/home?region=cn-northwest-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | AWS GovCloud (米国西部) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.amazonaws-us-gov.com/cloudformation/designer/home?region=us-gov-west-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.amazonaws-us-gov.com/cloudformation/home?region=us-gov-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.amazonaws-us-gov.com/cloudformation/home?region=us-gov-west-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | | AWS GovCloud (米国東部) | [表示](https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [デザイナーで表示](https://console.amazonaws-us-gov.com/cloudformation/designer/home?region=us-gov-east-1&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [https://console.amazonaws-us-gov.com/cloudformation/home?region=us-gov-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json](https://console.amazonaws-us-gov.com/cloudformation/home?region=us-gov-east-1#/stacks/new?stackName=NeptuneQuickStart&templateURL=https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json) | [**Create Stack (スタックの作成)**] ページで、[**Next (次へ)**] を選択します。 ## 作成する新しい OpenSearch スタックに関する詳細を追加する [**Specify Stack Details**] (スタック詳細の指定) ページには、フルテキスト検索の設定を制御するために使用できるプロパティとパラメータがあります。 **スタック名** –  作成する新しい 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` 測定に使用される時間単位 (分、時間、日)。通常は、デフォルト (分) で十分です。 + **`Enable/disable creation of Elastic Search Mappings by Lambda`** –  ストリームポーラーによる Elastic Search マッピングの自動管理を有効または無効にするフラグ。Elastic Search マッピングは、Neptune と Elastic Search データ型間の変換に不可欠です。これは、Elastic Search インデックス内のすべてのマッピングに対して直接の手動制御を引き受ける上級ユーザーのみが無効にする必要があります。デフォルトは `true` です。 + **`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`** – (必須) 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 メールの両方を追加できます。 ## CloudFormation テンプレートを実行する これで、次のように、Neptune ストリームコンシューマーアプリケーションインスタンスをプロビジョニングするプロセスを完了できます。 1. スタックの詳細 CloudFormationの指定ページで、**次へ** を選択します。 **** 1. [**Options(オプション)**] ページで、[**Next(次へ)**] を選択します。 1. [**確認**] ページで、 CloudFormation によって IAM リソースが作成されることを確認する最初のチェックボックスをオンにします。新しいスタックの `CAPABILITY_AUTO_EXPAND` を確認する 2 つ目のチェックボックスをオンにします。 **注記** `CAPABILITY_AUTO_EXPAND` は、スタックの作成時に事前の確認なしにマクロが展開されることを明示的に確認します。ユーザーは、処理されたテンプレートから変更セットを作成することが多いため、実際にスタックを作成する前にマクロによって行われた変更を確認できます。詳細については、 API *AWS CloudFormation リファレンス*の CloudFormation [CreateStack](https://docs.aws.amazon.com/AWSCloudFormation/latest/APIReference/API_CreateStack.html) API オペレーション」を参照してください。 次に **[作成]** を選択します。 # 既存の Neptune データベースでフルテキスト検索を有効にする これらは、既存の Amazon Neptune データベースでフルテキスト検索を有効にする確立されたアプローチです。書き込みワークロードを一時停止できるかどうかによって、ステップは若干異なる場合があります。このガイドでは、書き込みを一時停止できる場合と停止できない場合の両方のシナリオで推奨される手順の概要を説明します。Neptune ストリームの有効化、データベースクローンの作成、OpenSearch ドメインへのデータの同期、継続的な更新の設定について説明しています。このガイダンスでは、 AWS サービスとオープンソースツールを活用してプロセスを合理化し、ダウンタイムを最小限に抑えます。 ## 書き込みワークロードを一時停止できる場合 既存の Neptune データベースでフルテキスト検索を有効にする最良の方法は、書き込みワークロードを一時停止できれば、一般的に次の方法です。クローンを作成し、クラスターパラメータを使用してストリームを有効にし、すべてのインスタンスを再起動する必要があります。クローンの作成は比較的速いので、必要なダウンタイムは限られています。 必要な手順は次のとおりです。 1. データベース上のすべての書き込みワークロードを停止します。 1. データベースのストリームを有効にします (「[Neptune ストリームの有効化](streams-using-enabling.md)」を参照)。 1. データベースのクローンを作成します (「[Neptune でのデータベースクローニング](manage-console-cloning.md)」を参照)。 1. 書き込みワークロードを再開します。 1. github の [export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch) ツールを使用して、クローンされたデータベースから OpenSearch ドメインへの 1 回限りの同期を実行します。 1. [リージョン用のCloudFormation テンプレート](https://docs.aws.amazon.com/neptune/latest/userguide/full-text-search-cfn-create.html#full-text-search-cfn-by-region)を使用して、元のデータベースから同期して継続的な更新を行います (テンプレートで設定を変更する必要はありません)。 1. クローンされたデータベースと`export-neptune-to-elasticsearch`ツール用に作成された CloudFormation スタックを削除します。 **注記** Opensearch Serverless で [export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch) を使用する場合は、[export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch) Cloudformation スタックによって`LambdaExecutionRole`作成された を [Opensearch データアクセスポリシー](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/serverless-data-access.html)に追加して、データを正常にレプリケートする必要があります。 ## 書き込みワークロードを一時停止できない場合 データベースで書き込みワークロードを中断する余裕がない場合は、上記の推奨アプローチよりも少ないダウンタイムを必要とするアプローチを以下に示します。ただし、慎重に実行する必要があります。 1. データベースのストリームを有効にします (「[Neptune ストリームの有効化](streams-using-enabling.md)」を参照)。 1. データベースのクローンを作成します (「[Neptune でのデータベースクローニング](manage-console-cloning.md)」を参照)。 1. Streams API エンドポイントに対してこの種のコマンドを実行することによって、クローンされたデータベース上のストリームの最新の `eventID` を取得します (詳細については、「[Neptune Streams REST API の呼び出し](streams-using-api-call.md)」を参照)。 ``` curl "https://(your neptune endpoint):(port)/(propertygraph or sparql)/stream?iteratorType=LATEST" ``` レスポンス内の `lastEventId` オブジェクト内の `commitNum` および `opNum` フィールドの値を書き留めておきます。 1. github の [export-neptune-to-elasticsearch](https://github.com/awslabs/amazon-neptune-tools/tree/master/export-neptune-to-elasticsearch) ツールを使用して、クローンされたデータベースから OpenSearch ドメインへの 1 回限りの同期を実行します。 1. [リージョン用のCloudFormation テンプレート](https://docs.aws.amazon.com/neptune/latest/userguide/full-text-search-cfn-create.html#full-text-search-cfn-by-region)を使用して、元のデータベースから同期して継続的な更新を行います。 スタックの作成時に次の変更を行います。スタックの詳細ページの **Parameters** セクションで、上記で記録した `commitNum` および `opNum` の値を使用して、`StartingCheckpoint` フィールドの値を **commitNum**:**opnum** に設定します。 1. クローンされたデータベースと`export-neptune-to-elasticsearch`ツール用に作成された CloudFormation スタックを削除します。 # ストリームポーラーの更新 以下の情報は、 AWS マネジメントコンソールを使用してストリームポーラーを最新の Lambda アーティファクトで更新するために必要なステップの概要を示しています。 ## 最新の Lambda アーティファクトでストリームポーラーを更新するには 最新の Lambda アーティファクトで次のようにストリームポーラーを更新できます。 1. で AWS マネジメントコンソール、メインの親 CloudFormation スタックに移動 CloudFormation して選択します。 1. スタックの**[Update]** (更新) オプションを選択します。 1. **[Replace current template]** (現在のテンプレートを置換) を選択します。 1. テンプレートソースで、**Amazon S3 URL** を選択し、次の S3 URL を入力します。 ``` https://aws-neptune-customer-samples.s3.amazonaws.com/neptune-stream/neptune_to_elastic_search.json ``` 1. CloudFormation パラメータを変更せずに**次へ**を選択します。 1. [**Update Stack**] を選択します。 これで、スタックは Lambda アーティファクトを最新のアーティファクトで更新します。 ## ストリームポーラーを拡張してカスタムフィールドをサポートする 現在のストリームポーラーは、ブログ記事「[Neptune Streams を使用してグラフの変化を捕捉する](https://aws.amazon.com/blogs/database/capture-graph-changes-using-neptune-streams/)」で詳しく説明されているように、カスタムフィールドを処理するためのカスタムコードを記述するように簡単に拡張できます。 **注記** OpenSearch にカスタムフィールドを追加するときには、新しいフィールドを述語の内部オブジェクトとして追加するようにしてください ([Neptune フルテキスト検索データモデル](full-text-search-model.md) を参照)。 # ストリームポーラープロセスの無効化と再有効化 **警告** ストリームポーラープロセスを無効にするときは注意してください。ストリームの有効期限を超えてプロセスを一時停止すると、データが失われる可能性があります。デフォルトの期間は 7 日間ですが、エンジンバージョン [1.2.0.0](engine-releases-1.2.0.0.md) 以降では、カスタムストリームの有効期限を最大 90 日まで設定できます。 # ストリームポーラープロセスの無効化 (一時停止) 1. にサインイン AWS マネジメントコンソール し、[https://console.aws.amazon.com/events/](https://console.aws.amazon.com/events/) で Amazon EventBridge コンソールを開きます。 1. ナビゲーションペインで、**[Rules]** を選択します。 1. ストリームポーラーの設定に使用した CloudFormation テンプレートで**アプリケーション名**として指定した名前を含む名前のルールを選択します。 1. **[Disable]** (無効化) を選択します。 1. [https://console.aws.amazon.com/states/](https://console.aws.amazon.com/states/) で Step Functions コンソールを開きます。 1. ストリームポーラープロセスに対応するステップ実行関数を選択します。ここでも、そのステップ関数の名前には、ストリームポーラーの設定に使用した CloudFormation テンプレートで**アプリケーション名**として指定した名前が含まれています。関数の実行ステータスでフィルタリングすると、**実行中**の関数だけを表示できます。 1. **[停止]** を選択します。 # ストリームポーラープロセスの再有効化 1. にサインイン AWS マネジメントコンソール し、[https://console.aws.amazon.com/events/](https://console.aws.amazon.com/events/) で Amazon EventBridge コンソールを開きます。 1. ナビゲーションペインで、**[Rules]** を選択します。 1. ストリームポーラーの設定に使用した CloudFormation テンプレートで**アプリケーション名**として指定した名前を含む名前のルールを選択します。 1. **[有効化]** を選択します。指定したスケジュールされた間隔に基づくイベントルールが、ステップ関数の新しい実行をトリガーします。