サポートと今すぐチャット
サポートとのチャット

SharePlex 11.4 - インストールおよびセットアップガイド

このガイドについて このガイドで使用される表記規則 OracleソースへのSharePlexのインストールと設定
Oracle向けSharePlexプレインストールチェックリスト SharePlexインストーラのダウンロード Install SharePlex on Linux and UNIX（LinuxとUNIXへのSharePlexのインストール レプリケーションのためのOracle環境のセットアップ Oracleから異なるターゲットタイプへのレプリケーションを設定する Oracle向けクラウドホスト型データベースのインストールとセットアップ リモートキャプチャ向けインストールとセットアップ HAクラスタ向けインストールとセットアップ Oracle向け一般SharePlexデモ Oracle向け高度なSharePlexデモ データベース・セットアップ・ユーティリティ Oracleのインストールに関する問題の解決
ソースおよびサービスとしてのPostgreSQLデータベースへのSharePlexのインストールとセットアップ
PostgreSQL向けSharePlexのインストール前のチェックリスト PostgreSQL向けSharePlexインストーラのダウンロード ソースとしてのPostgreSQL向けLinuxへのSharePlexのインストール PostgreSQLからサポートされているターゲットタイプへのレプリケーションの設定 PostgreSQL向けクラウドホスト型データベースのインストールとセットアップ PostgreSQL向けリモートキャプチャのインストールとセットアップ PostgreSQL高可用性クラスタへのSharePlexのインストール 論理レプリケーションを使用した高可用性のPostgreSQL Azure Flexible ServerでのSharePlexの設定 PostgreSQL向けの汎用SharePlexデモ PostgreSQL用の高度なSharePlexデモ PostgreSQLのデータベースセットアップ PGDB as a Service向けデータベースセットアップ pg_hint_plan拡張機能のインストール PostgreSQLのインストールに関する問題の解決
DockerコンテナへのSharePlexのインストール SharePlexユーザのセキュリティグループへの割り当て インストールの問題の解決 SharePlexのアンインストール 高度なインストーラオプション rootとしてのSharePlexのインストール SharePlexでインストーラされるアイテム

PostgreSQLからKafkaへのレプリケーションの設定

概要

SharePlexのPostプロセスは、Kafkaブローカーに接続して書き込むことができます。データは、ソース上で発生した一連の操作として、JSONまたはXML出力に書き出すことができ、その後、Kafkaコンシューマーで消費することができます。

これらの説明書には、このターゲットに固有のセットアップ手順が含まれています。これらのセットアップ手順を実行する前に、本マニュアルの適切な指示に従って、SharePlexをソースとターゲットにインストールします。

SharePlexを使用してこのターゲットにレプリケートする場合、サポート対象のバージョン、データ型、操作については、『SharePlexリリースノート』を参照してください。

Kafkaカテゴリ

サポート対象

Kafka

コマンドオプション

KafkaのSP_CTRLで以下のコマンドオプションを使用します。

target x.kafka set kafka broker= 10.250.40.42:9092（KafkaサーバのIPアドレス:ポート番号）

target x.kafka set kafka topic= kafkaTarget（トピック名）

target x.kafka set format record = xml/JSON

target x.kafka show

Kafkaへのポストに関するガイドライン

  • SharePlexのPostプロセスはKafkaプロデューサーとして機能します。SharePlexのPostプロセスは、1つ以上のパーティションを持つ1つ以上のトピックに書き込むことができます。
  • SharePlexのPostプロセスではトピック自体は作成されませんが、トピックを自動的に作成するようにKafkaブローカーを設定することができます。

ソース上でのSharePlexの設定

Kafkaにデータをレプリケートする場合、ソースデータベースとソースシステム上のSharePlexを以下のように設定します。

レプリケーションの設定

ソース上で、captureおよびルーティング情報を指定するSharePlexの設定ファイルを作成します。設定ファイルに必要な構造はレプリケーション戦略によって異なりますが、Kafkaにデータをルーティングするために必要な構文をここに示します。

Datasource:r.dbname
src_schema.table !kafka host

ここで:

  • dbnameはソースのPostgreSQLデータベース名です。
  • src_schema.tableは、ソーステーブルのスキーマと名前です。
  • !kafkaは、SharePlexがKafkaにポストしていることを示す必須のキーワードです。

  • hostはターゲットシステムの名前です。

注意: 『SharePlex管理ガイド』の「データをレプリケートするためのSharePlexの設定

ソースの設定の例

Datasource:r.testdb

MY_SCHEMA.MY_TABLE !kafka targetHost

ターゲット上でのSharePlexの設定

これらの手順では、Kafkaに接続するようにSharePlexのPostプロセスを設定します。Kafkaブローカーが動作している必要があります。

Kafkaへのポストを設定するには、以下の手順を実行します。

  1. Kafkaトピックを作成します。
  2. sp_copを開始します(まだ設定を有効にしないでください）。
  3. sp_ctrlを実行します。

  4. targetコマンドを実行し、Kafkaブローカーとトピックへのポストを設定します。以下はコマンドの例です。

    sp_ctrl> target x.kafka set kafka broker=10.250.40.42:9092

    sp_ctrl> target x.kafkaset kafka topic=shareplex

    コマンドの説明とオプションについては、「PostgreSQLからKafkaへのレプリケーションの設定」を参照してください。

Kafkaのレコードフォーマットの設定

SharePlexは、Kafkaへの入力としてXMLまたはJSON形式で出力できます。XMLがデフォルトです。入力フォーマットを設定し、フォーマットオプションを指定するには、以下のいずれかのtargetコマンドを使用します。

target x.kafka set format record=json

または:

target x.kafka set format record=xml

これらのフォーマットのサンプルを表示するには、『SharePlexリファレンスガイド』に含まれるtargetコマンドのドキュメントのformatカテゴリを参照してください。

Kafkaの設定の表示と変更

Kafkaへの出力に関する現在のプロパティ設定を表示するには、以下のtargetコマンドを使用します。

target x.kafka show

表13: Kafkaターゲットプロパティ

プロパティ 入力値 デフォルト
broker=broker

必須。Kafkaブローカーのホストおよびポート番号、または複数のブローカーのコンマ区切りリスト。このリストがKafkaクラスタへのブートストラップとなります。これらのブローカーのいずれかに接続できれば、Postはクラスタ内の他のブローカーを検出します。

 localhost:9092
client_id=ID

オプション。呼び出しの追跡に役立つようにPostが各リクエストで送信するユーザ定義の文字列。

None
compression.code={none, gzip, snappy} オプション。Kafkaでデータを圧縮するかどうかを制御します。オプションはnone、gzip、またはsnappyです。 None
partition={number | rotate | rotate trans}

必須。次のいずれか:

  • 固定のパーティション番号: 指定されたパーティション番号にのみメッセージをポストするようにPostに指示します。例えば0に設定すると、Postはパーティション0にのみポストするようになります。このオプションは、テストでの使用や、同じKafkaトピックにポストするデータの複数のチャンネルがターゲットにある場合の用途に適しています。
  • キーワードrotate: トピックのすべてのパーティションにラウンドロビン方式でメッセージを適用するようにPostに指示します。パーティションは、メッセージが新しくなるたびに変わります。例えば、あるトピックに3つのパーティションがある場合、メッセージはパーティション0、1、2、0、1、2…の順番にポストされます。
  • キーワードrotate trans: これはrotateオプションと似ていますが、パーティションの番号が、メッセージごとではなくトランザクションごとに大きくなる点が異なります。例えば、あるトピックに3つのパーティションがある場合、コミットまではパーティション0に、コミットまではパーティション1にといった順番でメッセージがポストされます。このオプションは、複数のテーブルを1つのトピックに複製する場合に適しています。これにより、複数のパーティションにデータを分散させながら、トランザクションのすべての操作を単一のパーティションにまとめて保持することができます。その結果、単一のパーティションから読み取るコンシューマーは、完全なトランザクションのストリームを受け取ることができます。
0
request.required.acks=value

オプション。これはKafkaクライアントのパラメーターです。デフォルトでは-1に設定されており、allを意味します。実際にはallはall in-sync replicasを意味するため、これについてはKafkaのドキュメントを参照してください。このパラメーターは、min.insync.replicas brokerパラメーターと併用することで、可用性とデータの一貫性の関係を調整することができます。

重要: これらの設定によっては、Kafkaプロデューサー（この場合はSharePlex ）とKafkaクラスタの間でデータが失われる場合があります。

 -1
topic=topic_name

必須。ターゲットのKafkaトピックの名前。

この文字列には特殊なシーケンス%oまたは%tを含めることができます。シーケンス%oは、レプリケートされるテーブルのオーナー名に置き換えられます。%tのシーケンスは、複製されるテーブルのテーブル名に置き換えられます。この機能は、Kafkaサーバのauto.create.topics.enabledの設定が「true」に設定されている場合に使用できます。また、トピックが自動的に生成されるときのデフォルトとして使用されるため、default.replication.factorとnum.partitionsのサーバ設定も確認してください。

重要! 複数のトピックを使用する場合は、targetコマンドで以下のプロパティも設定する必要があります。

  • 出力はJSONでなければなりません。formatカテゴリのrecordプロパティをjsonに設定します。

    target x.kafka set format record=json

  • コミットは無効にしなければなりません。jsonカテゴリのcommitプロパティをnoに設定します。

    target x.kafka set json commit=no

 shareplex

*レイテンシを避けるために、Postはそれ以上着信メッセージがないことを検知すると、しきい値が満たされるのを待たずにKafkaに即座にパケットを送信します。

PostgreSQLからSQL Serverへのレプリケーションの設定

概要

SharePlexは、ODBC（Open Database Connectivity）インターフェイスを介して、レプリケートされたソースデータをMicrosoft SQL Serverターゲットデータベースにポストすることができます。

これらの説明書には、このターゲットに固有のセットアップ手順が含まれています。これらのセットアップ手順を実行する前に、本マニュアルの適切な指示に従って、SharePlexをソースとターゲットにインストールします。

SharePlexを使用してこのターゲットにレプリケートする場合、サポート対象のバージョン、データ型、操作については、『SharePlexリリースノート』を参照してください。

ソース上でのSharePlexの設定

SQL Serverにデータをレプリケートする場合、ソースデータベースとソースシステム上のSharePlexを以下のように設定します。

レプリケーションの設定

ソース上で、captureおよびルーティング情報を指定するSharePlexの設定ファイルを作成します。設定ファイルに必要な構造はレプリケーション戦略によって異なりますが、SQL Serverにデータをルーティングするために必要な構文をここに示します。

Datasource:r.dbname
src_schema.table tgt_owner.table host

ここで:

  • dbnameはソースのPostgreSQLデータベース名です。
  • src_schema.tableは、ソーステーブルのスキーマと名前です。

  • tgt_owner.tableは、ターゲットテーブルの所有者と名前です。

  • hostはターゲットシステムの名前です。

注意: 『SharePlex管理者ガイド』の「データをレプリケートするためのSharePlexの設定」を参照してください。

ソースの設定の例

以下の例では、PostgreSQLインスタンスdbnameAからホストsysprod上のMS SQL ServerにテーブルSCOTT.EMPをレプリケートします。

Datasource: r.testdb
SCOTT.EMP    SCOTT.EMP   sysprod@r.mydb

ターゲット上でのSharePlexの設定

以下の手順を実行して、ターゲット上でSharePlexを構成します。

  1. データベースのセットアップが、「Open Targetチェックリストページの要件をすべて満たしていることを確認します。

  2. SQL Serverのデータベースセットアップ（mss_setup）を実行し、SharePlexのデータベースアカウントと接続情報を確立します。詳細については、SQL Serverのデータベースセットアップを参照してください。

PostgreSQL向けクラウドホスト型データベースのインストールとセットアップ

内容

 

クラウド上でのPostgreSQL向けSharePlexのセットアップの概要

SharePlexは、Amazon Web Services（AWS）、Google Cloud SQL for PostgreSQL、Microsoft Azureのサービスとしてインストールされたデータベースをサポートしています。SharePlexがサポートするクラウドデータベースについては、各データベースの『SharePlexリリースノート』の「サポート対象のクラウドプラットフォーム」を参照してください。

IaaSクラウド環境、PaaSクラウド環境、SaaSクラウド環境では、SharePlexのインストール方法にいくつかの違いがあります。これらの違いは、SharePlexのインストールと設定についてのみです。一度インストールして設定すれば、SharePlexはクラウドでもオンプレミスと同じように動作します。さまざまな環境へのSharePlexのインストール方法の詳細については、「クラウド上でのSharePlexのセットアップの概要」を参照してください。

関連ドキュメント

The document was helpful.

評価を選択

I easily found the information I needed.

評価を選択