Google は AI 技術を使用して、コンテンツをご希望の言語に翻訳しています。AI 翻訳には誤りが含まれる場合があります。

ID コネクタを作成する

デフォルトでは、Google Cloud Search は Google Cloud Directory 内の Google ID のみ認識します。企業の ID を Cloud Search で使用される Google ID と同期するには、ID コネクタを使用します。

Google は、ID コネクタを開発するための以下のオプションを提供しています。

Identity Connector SDK: Java プログラマーに最適です。この SDK は、コネクタをすばやく作成するための REST API を簡単に使えるようにしたラッパーです。SDK を使用するには、次を参照してください。Identity Connector SDK を使用して ID コネクタを作成する。
低レベル REST API と API ライブラリ: Java プログラマー以外に最適です。REST API を使用して ID コネクタを作成する際、ユーザーのマッピングについては Directory API: ユーザーアカウントを、グループのマッピングについては Google Cloud Identity のドキュメントをご覧ください。

Identity Connector SDK を使用して ID コネクタを作成する

一般的な ID コネクタは、次のタスクを実行します。

コネクタを構成する。
ID システムからユーザーを取得して Google に送信する。
ID システムからグループを取得して Google に送信する。

依存関係を設定する

ビルドファイルに次の依存関係を含めます。

Maven

<dependency>
  <groupId>com.google.enterprise.cloudsearch</groupId>
  <artifactId>google-cloudsearch-identity-connector-sdk</artifactId>
  <version>v1-0.0.3</version>
</dependency>

Gradle

compile group: 'com.google.enterprise.cloudsearch',
        name: 'google-cloudsearch-identity-connector-sdk',
        version: 'v1-0.0.3'

コネクタ構成を作成する

すべてのコネクタは、リポジトリ ID などのパラメータに構成ファイルを使用します。パラメータは、Key-Value ペアとして定義します。 api.sourceId=1234567890abcdef

Google Cloud Search SDK には、すべてのコネクタ用の Google 提供パラメータが含まれています。構成ファイルで次の項目を宣言する必要があります。

コンテンツコネクタ: api.sourceId と api.serviceAccountPrivateKeyFile を宣言します。これらは、リポジトリとアクセスに必要な秘密鍵を識別します。

ID コネクタ: api.identitySourceId を宣言して、外部 ID ソースを識別します。ユーザーの同期を行う場合は、api.customerId（Google Workspace アカウントの一意の ID）も宣言します。

他の Google 提供パラメータは、デフォルト値をオーバーライドする場合にのみ宣言します。 ID と鍵の生成の詳細については、 Google 提供パラメータをご覧ください。

構成ファイルでリポジトリ固有のパラメータを定義することもできます。

構成ファイルをコネクタに渡す

構成ファイルを渡すには、config システムプロパティを設定します。コネクタを起動するときに -D 引数を使用します。次に例を示します。

java -classpath myconnector.jar -Dconfig=MyConfig.properties MyConnector

この引数を省略すると、SDK はローカルディレクトリにある connector-config.properties という名前のファイルを使用しようとします。

テンプレートクラスを使用して完全同期 ID コネクタを作成する

SDK には、リポジトリからすべてのユーザーとグループを同期するための FullSyncIdentityConnector テンプレートが含まれています。このセクションでは、その使用方法について説明します。

このセクションでは、CSV ファイルから ID を読み取る IdentityConnectorSample.java サンプルのコードを参照します。

コネクタのエントリポイントを実装する

エントリポイントは main() メソッドです。 Application インスタンスを作成し、 start() を呼び出してコネクタを実行します。

application.start() を呼び出す前に、 IdentityApplication.Builder を使用して FullSyncIdentityConnector テンプレートをインスタンス化します。

IdentityConnectorSample.java

GitHub で表示

/**
 * This sample connector uses the Cloud Search SDK template class for a full
 * sync connector. In the full sync case, the repository is responsible
 * for providing a snapshot of the complete identity mappings and
 * group rosters. This is then reconciled against the current set
 * of mappings and groups in Cloud Directory.
 *
 * @param args program command line arguments
 * @throws InterruptedException thrown if an abort is issued during initialization
 */
public static void main(String[] args) throws InterruptedException {
  Repository repository = new CsvRepository();
  IdentityConnector connector = new FullSyncIdentityConnector(repository);
  IdentityApplication application = new IdentityApplication.Builder(connector, args).build();
  application.start();
}

main() メソッドが Application.build() を呼び出すと、SDK は initConfig() を呼び出します。initConfig() メソッドは次の処理を行います。

Configuration がまだ初期化されていないことを確認します。
Google 提供の Key-Value ペアで Configuration オブジェクトを初期化します。

Repository インターフェースを実装する

Repository オブジェクトは、リポジトリ ID を Google ID と同期します。テンプレートを使用する場合は、特定のメソッドのみをオーバーライドする必要があります。FullSyncIdentityConnector の場合は、次のメソッドをオーバーライドします。

init(): 設定と初期化用。
listUsers(): すべてのユーザーを同期する場合。
listGroups(): すべてのグループを同期する場合。
（省略可）close(): シャットダウン時のクリーンアップ用。

カスタム構成パラメータを取得する

カスタムパラメータは、通常 init() メソッドで Configuration オブジェクトから取得します。次のスニペットは、CSV パスを取得する方法を示しています。

IdentityConnectorSample.java

GitHub で表示

/**
 * Initializes the repository once the SDK is initialized.
 *
 * @param context Injected context, contains convenienve methods
 *                for building users & groups
 * @throws IOException if unable to initialize.
 */
@Override
public void init(RepositoryContext context) throws IOException {
  log.info("Initializing repository");
  this.context = context;
  userMappingCsvPath = Configuration.getString(
      "sample.usersFile", "users.csv").get().trim();
  groupMappingCsvPath = Configuration.getString(
      "sample.groupsFile", "groups.csv").get().trim();
}

複数の値を含むパラメータを取得して解析するには、Configuration クラスのいずれかの型パーサーを使用してデータを個別のチャンクに解析します。次のコードスニペット（チュートリアルコネクタからの抜粋）は、 getMultiValue メソッドを使用して GitHub リポジトリの名前のリストを取得しています。

GithubRepository.java

GitHub で表示

ConfigValue<List<String>> repos = Configuration.getMultiValue(
    "github.repos",
    Collections.emptyList(),
    Configuration.STRING_PARSER);

すべてのユーザーのマッピングを取得する

listUsers() をオーバーライドして、ユーザーマッピングを取得します。このメソッドは、中断された場合に同期を再開するためのチェックポイントを受け取ります。ユーザーごとに次の処理を行います。

Google ID と外部 ID の間のマッピングを取得します。
listUsers() から返されたイテレータにペアをパッケージ化します。

ユーザーマッピングを取得する

次のスニペットは、CSV ファイルから ID マッピングを取得する方法を示しています。

IdentityConnectorSample.java

GitHub で表示

/**
 * Retrieves all user identity mappings for the identity source. For the
 * full sync connector, the repository must provide a complete snapshot
 * of the mappings. This is reconciled against the current mappings
 * in Cloud Directory. All identity mappings returned here are
 * set in Cloud Directory. Any previously mapped users that are omitted
 * are unmapped.
 *
 * The connector does not create new users. All users are assumed to
 * exist in Cloud Directory.
 *
 * @param checkpoint Saved state if paging over large result sets. Not used
 *                   for this sample.
 * @return Iterator of user identity mappings
 * @throws IOException if unable to read user identity mappings
 */
@Override
public CheckpointCloseableIterable<IdentityUser> listUsers(byte[] checkpoint)
    throws IOException {
  List<IdentityUser> users = new ArrayList<>();
  try (Reader in = new FileReader(userMappingCsvPath)) {
    // Read user mappings from CSV file
    CSVParser parser = CSVFormat.RFC4180
        .withIgnoreSurroundingSpaces()
        .withIgnoreEmptyLines()
        .withCommentMarker('#')
        .parse(in);
    for (CSVRecord record : parser.getRecords()) {
      // Each record is in form: "primary_email", "external_id"
      String primaryEmailAddress = record.get(0);
      String externalId = record.get(1);
      if (primaryEmailAddress.isEmpty() || externalId.isEmpty()) {
        // Skip any malformed mappings
        continue;
      }
      log.info(() -> String.format("Adding user %s/%s",
          primaryEmailAddress, externalId));

      // Add the identity mapping
      IdentityUser user = context.buildIdentityUser(
          primaryEmailAddress, externalId);
      users.add(user);
    }
  }
  // ...
}

イテレータにユーザーマッピングをパッケージ化する

listUsers() メソッドは、 CheckpointCloseableIterable の IdentityUser オブジェクトを返します。

IdentityConnectorSample.java

GitHub で表示

CheckpointCloseableIterable<IdentityUser> iterator =
  new CheckpointCloseableIterableImpl.Builder<IdentityUser>(users)
      .setHasMore(false)
      .setCheckpoint((byte[])null)
      .build();

グループを取得する

listGroups() をオーバーライドして、グループとそのメンバーを取得します。このメソッドはチェックポイントを受け取ります。グループごとに次の処理を行います。

グループとそのメンバーを取得します。
listGroups() から返されたイテレータにパッケージ化します。

グループ ID を取得する

次のスニペットは、CSV ファイルからグループとメンバーを取得する方法を示しています。

IdentityConnectorSample.java

GitHub で表示

/**
 * Retrieves all group rosters for the identity source. For the
 * full sync connector, the repository must provide a complete snapshot
 * of the rosters. This is reconciled against the current rosters
 * in Cloud Directory. All groups and members  returned here are
 * set in Cloud Directory. Any previously created groups or members
 * that are omitted are removed.
 *
 * @param checkpoint Saved state if paging over large result sets. Not used
 *                   for this sample.
 * @return Iterator of group rosters
 * @throws IOException if unable to read groups
 */    @Override
public CheckpointCloseableIterable<IdentityGroup> listGroups(byte[] checkpoint)
    throws IOException {
  List<IdentityGroup> groups = new ArrayList<>();
  try (Reader in = new FileReader(groupMappingCsvPath)) {
    // Read group rosters from CSV
    CSVParser parser = CSVFormat.RFC4180
        .withIgnoreSurroundingSpaces()
        .withIgnoreEmptyLines()
        .withCommentMarker('#')
        .parse(in);
    for (CSVRecord record : parser.getRecords()) {
      // Each record is in form: "group_id", "member"[, ..., "memberN"]
      String groupName = record.get(0);
      log.info(() -> String.format("Adding group %s", groupName));
      // Parse the remaining columns as group memberships
      Supplier<Set<Membership>> members = new MembershipsSupplier(record);
      IdentityGroup group = context.buildIdentityGroup(groupName, members);
      groups.add(group);
    }
  }
  // ...

}

グループとメンバーをイテレータにパッケージ化する

listGroups() メソッドは、CheckpointCloseableIterable オブジェクトの IdentityGroup を返します。

IdentityConnectorSample.java

GitHub で表示

CheckpointCloseableIterable<IdentityGroup> iterator =
   new CheckpointCloseableIterableImpl.Builder<IdentityGroup>(groups)
      .setHasMore(false)
      .setCheckpoint((byte[])null)
      .build();

次のステップ

（省略可）リソースを解放する close() を実装します。
（省略可）コンテンツコネクタを作成します。

ID コネクタを作成する コレクションでコンテンツを整理 必要に応じて、コンテンツの保存と分類を行います。

Identity Connector SDK を使用して ID コネクタを作成する

依存関係を設定する

Maven

Gradle

コネクタ構成を作成する

構成ファイルをコネクタに渡す

テンプレート クラスを使用して完全同期 ID コネクタを作成する

コネクタのエントリ ポイントを実装する

Repository インターフェースを実装する

カスタム構成パラメータを取得する

すべてのユーザーのマッピングを取得する

ユーザー マッピングを取得する

イテレータにユーザー マッピングをパッケージ化する

グループを取得する

グループ ID を取得する

グループとメンバーをイテレータにパッケージ化する

次のステップ

ID コネクタを作成する

テンプレートクラスを使用して完全同期 ID コネクタを作成する

コネクタのエントリポイントを実装する

ユーザーマッピングを取得する

イテレータにユーザーマッピングをパッケージ化する