ジョブのオフロード

はじめに

オフロードは、トポロジ内のExperience Managerインスタンス間で処理タスクを分散します。 オフロードでは、特定の Experience Manager インスタンスを使用して、特定のタイプの処理を実行できます。処理を特化することによって、利用可能なサーバーリソースを最大限に使用できます。

オフロードは、Apache Sling DiscoveryおよびSling JobManagerの機能に基づいています。オフロードを使用するには、Experience Managerクラスターをトポロジに追加し、クラスターが処理するジョブトピックを特定します。クラスターは、1つ以上のExperience Managerインスタンスで構成され、1つのインスタンスがクラスターと見なされます。

トポロジへのインスタンスの追加について詳しくは、トポロジの管理を参照してください。

ジョブ配布

Sling JobManager と JobConsumer を使用して、トポロジ内で処理されるジョブを作成できます。

• JobManager：特定のトピックのジョブを作成するサービス。
• JobConsumer：1 つ以上のトピックのジョブを実行するサービス。同じトピックに対して複数の JobConsumer サービスを登録できます。

JobManager でジョブが作成されると、オフロードフレームワークによって、ジョブを実行するトポロジ内の Experience Manager クラスターが選択されます。

• クラスターには、ジョブトピックに対して登録された JobConsumer を実行している 1 つ以上のインスタンスが含まれている必要があります。
• トピックは、クラスター内の少なくとも 1 つのインスタンスに対して有効化されている必要があります。

ジョブ配布の調整について詳しくは、トピック使用の設定を参照してください。

オフロードフレームワークで、ジョブを実行するクラスターを選択し、そのクラスターが複数のインスタンスで構成されている場合、Sling Distributionは、ジョブを実行するクラスター内のインスタンスを決定します。

ジョブペイロード

オフロードフレームワークでは、ジョブをリポジトリ内のリソースと関連付けるジョブペイロードがサポートされています。ジョブペイロードは、ジョブがリソースを処理するために作成されたり、別のコンピューターにオフロードされたりする場合に役立ちます。

ジョブの作成時に、ペイロードはそのジョブを作成するインスタンスにのみ配置されることが保証されます。ジョブのオフロード時に、レプリケーションエージェントによって、ペイロードが最終的にジョブを使用するインスタンスで作成されます。ジョブ実行が完了すると、リバースレプリケーションによって、ペイロードのコピーがジョブを作成したインスタンスに戻されます。

トポロジの管理

トポロジは、オフロードに参加する疎結合された Experience Manager クラスターです。クラスターは 1 つ以上の Experience Manager サーバーインスタンスで構成されます（単一のインスタンスがクラスターと見なされます）。

各 Experience Manager インスタンスによって、以下のオフロード関連サービスが実行されます。

• Discovery Service：トポロジに参加するために Topology Connector に要求を送信します。
• Topology Connector：参加要求を受信し、各要求を承認または拒否します。

トポロジのすべてのメンバーの Discovery Service は、メンバーのうちの 1 つの Topology Connector を参照しています。以下の節では、このメンバーをルートメンバーと呼びます。

トポロジ内の各クラスターには、リーダーと認識されるインスタンスが含まれています。クラスターリーダーは、クラスターの他のメンバーの代わりにトポロジとやり取りします。リーダーがクラスターから外れると、クラスターの新しいリーダーが自動的に選択されます。

トポロジの表示

トポロジブラウザーを使用して、Experience Manager インスタンスが参加しているトポロジの状態を調べます。トポロジブラウザーには、トポロジのクラスターおよびインスタンスが表示されます。

各クラスターには、各メンバーがクラスターに参加した順序とリーダーであるメンバーを示すクラスターメンバーのリストが表示されます。 現在プロパティによって、現在管理しているインスタンスが示されます。

クラスターの各インスタンスについて、複数のトポロジ関連プロパティを確認できます。

• インスタンスのジョブコンシューマーに関するトピックの許可リスト。
• トポロジとの接続用に公開されるエンドポイント
• インスタンスがどのジョブトピックについてオフロード用に登録されているか
• インスタンスによって処理されるジョブトピック

1. タッチ UI を使用して、「ツール」タブをクリックします（http://localhost:4502/tools.html）。

2. Granite の操作エリアで、「オフロードするブラウザー」をクリックします。

3. ナビゲーションパネルで、「トポロジブラウザー」をクリックします。

   トポロジに参加しているクラスターが表示されます。

   

4. クラスターをクリックして、クラスターのインスタンスとそれらの ID、現在ステータスおよびリーダーステータスのリストを表示します。

5. インスタンス ID をクリックして、詳細なプロパティを表示します。

Web コンソールを使用してトポロジ情報を表示することもできます。コンソールには、トポロジのクラスターに関するその他の情報が表示されます。

• どのインスタンスがローカルインスタンスであるか
• このインスタンスがトポロジに接続するために使用する Topology Connector サービス（送信）と、このインスタンスに接続するサービス（受信）
• トポロジおよびインスタンスのプロパティの履歴を変更します。

以下の手順を使用して、Web コンソールのトポロジ管理ページを開きます。

1. ブラウザーで Web コンソールを開きます（http://localhost:4502/system/console）。

2. Main／Topology Management をクリックします。

   

トポロジメンバーシップの設定

Experience Manager インスタンスとトポロジとのインタラクション方法を制御するために、Apache Sling のリソースベースの Discovery Service が各インスタンスで実行されます。

Discovery Service によって、トポロジとの接続を確立および維持するために、定期的な POST 要求（ハートビート）が Topology Connector サービスに送信されます。Topology Connectorサービスは、トポロジへの参加を許可されるIPアドレスまたはホスト名の許可リストを維持します。

• インスタンスをトポロジに参加させるには、ルートメンバーの Topology Connector サービスの URL を指定します。
• インスタンスがトポロジに参加できるようにするには、ルートメンバーの Topology Connector サービスの許可リストにインスタンスを追加します。

Web コンソールまたは sling:OsgiConfig ノードを使用して、org.apache.sling.discovery.impt.Config サービスの以下のプロパティを設定します。

以下の手順を使用して、CQ インスタンスをトポロジのルートメンバーに接続します。この手順では、インスタンスがルートトポロジメンバーの Topology Connector URL を指すようにします。この手順をトポロジのすべてのメンバーで実行します。

1. ブラウザーで Web コンソールを開きます（http://localhost:4502/system/console）。
2. Main／Topology Management をクリックします。
3. 「 Configure Discovery Service」をクリックします。
4. Topology Connector URL プロパティに項目を追加し、ルートトポロジメンバーの Topology Connector サービスの URL を指定します。URLは、https://rootservername:4502/libs/sling/topology/connectorの形式で指定します。

トポロジのルートメンバーで以下の手順を実行します。この手順では、ルートメンバーの Discovery Service 許可リストに他のトポロジメンバーの名前を追加します。

1. ブラウザーで Web コンソールを開きます（http://localhost:4502/system/console）。
2. Main／Topology Management をクリックします。
3. 「 Configure Discovery Service」をクリックします。
4. トポロジの各許可リストに対して、Topology Connectorメンバーのプロパティに項目を追加し、トポロジメンバーのホスト名またはIPアドレスを指定します。

トピック使用の設定

オフロードするブラウザーを使用して、トポロジ内の Experience Manager インスタンスのトピック使用を設定します。インスタンスごとに、使用するトピックを指定できます。例えば、1 つのインスタンスのみが特定のタイプのトピックを使用するようにトポロジを設定するには、その 1 つのインスタンスを除くすべてのインスタンスでそのトピックを無効にします。

ジョブは、関連するトピックが有効になっているインスタンス間で、ラウンドロビンロジックを使用して分散されます。

1. タッチ UI を使用して、「ツール」タブをクリックします（http://localhost:4502/tools.html）。

2. Granite の操作エリアで、「オフロードするブラウザー」をクリックします。

3. ナビゲーションパネルで、「オフロードするブラウザー」をクリックします。

   オフロードトピックと、トピックを使用できるサーバーインスタンスが表示されます。

   

4. インスタンスのトピックの使用を無効にするには、トピック名の下で、インスタンスの横にある「無効にする」をクリックします。

5. あるインスタンスのすべてのトピック使用を設定するには、トピックの下にあるインスタンス識別子をクリックします。

   

6. トピックの横にある以下のボタンのいずれかをクリックし、インスタンスの使用動作を設定して、「保存」をクリックします。

   • 有効：このインスタンスはこのトピックのジョブを使用します。
   • 無効：このインスタンスはこのトピックのジョブを使用しません。
   • 排他：このインスタンスはこのトピックのみのジョブを使用します。

   注意：​あるトピックに対して「排他」を選択すると、他のすべてのトピックは自動的に「無効」に設定されます。

インストール済みの JobConsumer

複数の JobConsumer 実装が Experience Manager とともにインストールされます。これらの JobConsumer が登録されているトピックが、オフロードするブラウザーに表示されます。表示されるその他のトピックは、カスタム JobConsumer で登録されたトピックです。以下の表に、デフォルトの JobConsumer を示します。

インスタンスのトピックの無効化と有効化

Apache Sling JobConsumer Manager サービスによって、トピックの許可リストプロパティとブロックリストプロパティが提供されます。これらのプロパティを設定して、Experience Manager インスタンスでの特定のトピックの処理を有効または無効にします。

注意：​インスタンスがトポロジに属している場合は、トポロジ内の任意のコンピューターでオフロードするブラウザーを使用して、トピックを有効または無効にすることもできます。

有効化されたトピックのリストを作成するロジックでは、まず許可リスト内のすべてのトピックを許可した後、ブロックリスト内のトピックを削除します。デフォルトでは、すべての許可リストが有効になり（トピックの値は*）、無効になるトピックはありません(ブロックリストに値がありません)。

Web コンソールまたは sling:OsgiConfig ノードを使用して、以下のプロパティを設定します。sling:OsgiConfig ノードの場合、JobConsumer Manager サービスの PID は、org.apache.sling.event.impl.jobs.JobConsumerManager です。

オフロードのレプリケーションエージェントの作成

オフロードフレームワークでは、作成者とワーカー間のリソースの転送にレプリケーションが使用されます。インスタンスがトポロジに参加すると、オフロードフレームワークによってレプリケーションエージェントが自動的に作成されます。エージェントはデフォルト値を使用して作成されます。エージェントが認証に使用するパスワードを手動で変更する必要があります。

オフロードのためにインスタンス間でジョブペイロードを転送するレプリケーションエージェントを作成します。以下の図に、作成者からワーカーインスタンスへのオフロードに必要なエージェントを示します。オーサーのSling IDは1で、ワーカーインスタンスのSling IDは2です。

この設定では、以下の 3 つのエージェントが必要です。

1. ワーカーインスタンスへレプリケートする、オーサーインスタンス上の送信エージェント
2. ワーカーインスタンス上のアウトボックスから引き出す、オーサーインスタンス上のリバースエージェント
3. ワーカーインスタンス上のアウトボックスエージェント

このレプリケーションスキームは、オーサーインスタンスとパブリッシュインスタンスの間で使用されるものと同様です。ただし、オフロードの場合は、関係するすべてのインスタンスはオーサーインスタンスです。

オフロードのレプリケーションエージェントの命名

オフロードフレームワークが特定のワーカーインスタンスに対して正しいエージェントを自動的に使用するように、レプリケーションエージェントの​名前​プロパティに特定の形式を使用します。

オーサーインスタンスの送信エージェントの命名：

offloading_<slingid>( <slingid> はワーカーインスタンスのSling IDです)。

例: offloading_f5c8494a-4220-49b8-b079-360a72f71559

オーサーインスタンスのリバースエージェントの命名：

offloading_reverse_<slingid>( <slingid> はワーカーインスタンスのSling IDです)。

例: offloading_reverse_f5c8494a-4220-49b8-b079-360a72f71559

ワーカーインスタンスのアウトボックスの命名：

offloading_outbox

送信エージェントの作成

1. 作成者で​レプリケーションエージェント​を作成します（レプリケーションエージェント🔗のドキュメントを参照）。 任意の​タイトル​を指定します。 名前​は、命名規則に従う必要があります。

2. 以下のプロパティを使用してエージェントを作成します。

   プロパティ	値
   設定／シリアル化の種類	デフォルト
   トランスポート／トランスポート URI	https://<ip of target instance>:<port>/bin/receive?sling:authRequestLogin=1
   トランスポート／トランスポートユーザー	ターゲットインスタンスのレプリケーションユーザー
   トランスポート/トランスポートパスワード	ターゲットインスタンスのレプリケーションユーザーパスワード
   拡張／HTTP メソッド	POST
   トリガー／デフォルトを無視	True

リバースエージェントの作成

1. オーサー環境に​リバースレプリケーションエージェント​を作成します。 （レプリケーションエージェント🔗のドキュメントを参照）。 任意の​タイトル​を指定します。 名前​は、命名規則に従う必要があります。

2. 以下のプロパティを使用してエージェントを作成します。

   プロパティ	値
   設定／シリアル化の種類	デフォルト
   トランスポート／トランスポート URI	https://<ip of target instance>:<port>/bin/receive?sling:authRequestLogin=1
   トランスポート／トランスポートユーザー	ターゲットインスタンスのレプリケーションユーザー
   トランスポート/トランスポートパスワード	ターゲットインスタンスのレプリケーションユーザーパスワード
   拡張／HTTP メソッド	GET

アウトボックスエージェントの作成

1. ワーカーインスタンス上に​レプリケーションエージェント​を作成します。 （レプリケーションエージェント🔗のドキュメントを参照）。 任意の​タイトル​を指定します。 名前​はoffloading_outboxにする必要があります。

2. 以下のプロパティを使用してエージェントを作成します。

   プロパティ	値
   設定／シリアル化の種類	デフォルト
   トランスポート／トランスポート URI	repo://var/replication/outbox
   トリガー／デフォルトを無視	True

Sling ID の検索

以下のいずれかの方法を使用して、Experience Manager インスタンスの Sling ID を取得します。

• Webコンソールを開き、Sling設定でSling IDプロパティの値を探します(http://localhost:4502/system/console/status-slingsettings)。 この方法は、インスタンスがまだトポロジの一部でない場合に役立ちます。
• インスタンスが既にトポロジの一部である場合は、トポロジブラウザーを使用します。

参考情報

このページで説明した詳細以外に、以下を参照することもできます。

• Java APIを使用したジョブおよびジョブコンシューマーの作成について詳しくは、オフロード用のジョブの作成と使用を参照してください。