Application Integration でサポートされているコネクタをご覧ください。
コネクタタスク
コネクタタスクでは、すぐに利用できるIntegration Connectors のコネクタを使用して、統合からさまざまな Google Cloud サービスやその他のビジネス アプリケーションにすばやく確実に接続できます。
Application Integration でサポートされているすべてのコネクタのリストについては、コネクタ リファレンスをご覧ください。始める前に
- Google Cloud プロジェクトに対してコネクタ管理者(
roles/connectors.admin
)IAM ロールが付与されていることを確認します。ロールの付与の詳細については、アクセスの管理をご覧ください。 - Integration Connectors の一般的なコンセプトについて確認します。
- コネクタを使用して Google Cloud サービスや他のビジネス アプリケーションに接続するには、ご使用の Integration にユーザー管理のサービス アカウントが接続されていることを確認してください。ご使用の Integration にユーザー管理のサービス アカウントが構成されていない場合は、デフォルトで、デフォルトのサービス アカウント(
service-PROJECT_NUMBER@gcp-sa-integrations.iam.gserviceaccount.com
)が認証に使用されます。 - サービス アカウントに必要な IAM ロールがあることを確認します。サービス アカウントへのロールの付与については、サービス アカウントに対するアクセス権の管理をご覧ください。
コネクタタスクを追加する
統合にコネクタタスクを追加する手順は次のとおりです。
- Google Cloud コンソールで [Application Integration] ページに移動します。
- ナビゲーション メニューで [統合] をクリックします。
[統合] ページが開き、Google Cloud プロジェクトで使用可能なすべての統合が一覧表示されます。
- 既存の統合を選択するか、[統合の作成] をクリックして新しい統合を作成します。
新しい統合を作成する場合:
- [統合の作成] ペインで名前と説明を入力します。
- 統合のリージョンを選択します。
- 統合用のサービス アカウントを選択します。統合のサービス アカウントの詳細は、統合ツールバーの [統合の概要] ペインでいつでも変更または更新できます。
- [作成] をクリックします。
統合デザイナーで統合が開きます。
- 統合エディタのナビゲーション バーで、[タスク] をクリックして、使用可能なタスクのリストを表示します。
- 統合エディタで [Connectors] 要素をクリックして配置します。
コネクタタスクを構成する
コネクタタスクを構成するには、次の手順を行います。
- デザイナーで [コネクタ] タスク要素をクリックして、[コネクタ] タスク構成ペインを表示します。
必要に応じて、[
] をクリックしてタスク名を変更します。 - [コネクタを設定する] をクリックします。
- リージョン内で既存の接続を選択するか、新しい接続を作成することができます。既存の接続を構成するには、[Connectors Task Editor] ページで次の手順を完了させます。
- [Select Connectors] で、接続のリージョンを選択します。
- 選択したリージョンで利用可能な接続のリストから、既存の接続を選択します。
- [次へ] をクリックします。
- [タイプ] リストで [エンティティ] または [アクション] を選択します。
- [エンティティ] を選択すると、接続でサポートされているエンティティのリストが [Set entities/actions] セクションに表示されます。エンティティを選択してから、そのエンティティで行う [オペレーション] を選択します。
- [アクション] を選択すると、接続でサポートされているアクションのリストが [Set entities/actions] 列に表示されます。接続のアクションを選択します。 サポートされるエンティティとアクションは、コネクタタイプに基づいて決まります。Application Integration でサポートされているすべてのコネクタの一覧については、コネクタ リファレンスをご覧ください。コネクタでサポートされているアクションとエンティティを表示するには、特定のコネクタのドキュメントをご覧ください。
コネクタがカスタム SQL クエリをサポートしている場合は、[アクション] リストで [カスタムクエリを実行する] オプションを選択します。たとえば、BigQuery コネクタのカスタム SQL クエリを追加する方法については、カスタム SQL クエリを実行するをご覧ください。
エンティティとアクションの詳細については、エンティティ、オペレーション、アクションをご覧ください。
- [完了] をクリックして接続の構成を完了し、ペインを閉じます。
次の画像は、[Connectors Task Editor] ページのサンプル レイアウトを示しています。
タスクの入出力変数を構成する
コネクタタスク構成ペインには、[Configure connector task] ダイアログで選択したエンティティとオペレーションまたはアクションに基づいて自動生成されたタスク入力とタスク出力の変数が表示されます。これらの変数は構成可能です。これらの変数は、現在のタスクへの入力として、または現在の統合で後続のタスクまたは条件への出力としてアクセスできます。
タスク入力変数またはタスク出力変数を構成するには、それぞれの変数をクリックして、[Configure Variable] ペインを開き、次の手順を行います。
- [デフォルト値] フィールドに変数値を入力します。
- (省略可)[Use as an input to integration] または [Use as an output to integration] を選択します。
- [保存] をクリックします。
コネクタタスクの入出力パラメータの詳細については、エンティティ オペレーションをご覧ください。
エンティティ オペレーション
コネクタのエンティティで CRUD(作成、読み取り、更新、削除)オペレーションを行うことができます。これらのエンティティ オペレーションでは、それぞれ入力パラメータと出力パラメータのセットが異なります。次のテーブルに、さまざまなエンティティ オペレーションの入力パラメータと出力パラメータが示されています。
オペレーション名 | 入力パラメータ | 出力パラメータ |
---|---|---|
List(リスト) |
|
|
Get(取得) | entityId | connectorOutputPayload |
Create(作成) | connectorInputPayload | connectorOutputPayload |
Update(更新) |
|
connectorOutputPayload |
Delete(削除) |
|
該当なし |
入力パラメータ
次のテーブルに、さまざまなエンティティ オペレーションの入力パラメータを示します。
パラメータ名 | データ型 | 説明 |
---|---|---|
entityId | 文字列 | アクセスする行の一意の識別子。 通常、 たとえば、MySQL テーブルから特定の行を取得するには、 |
connectorInputPayload | JSON | エンティティで追加または更新される実際のデータ。次の例は、テーブルに追加される行データの JSON スニペットを示しています。{ "employee_first_name": "John", "employee_emailID": "[email protected]" } この例では、 |
filterClause | 文字列 | 条件に基づいてオペレーションの結果を制限します。フィルタ句の追加について詳しくは、オペレーション用のフィルタを追加するをご覧ください。 |
listEntitiesPageSize | 整数 |
ページで返される結果の数を指定します。 ページは、結果セットのレコードの論理グループです。ページのコンセプトは、結果セットに多数のレコードが含まれることが予想される場合に有効に活用できます。結果セットのサイズが大きい場合、コネクタタスクが処理できるデータサイズには上限があるため、コネクタタスクが失敗する可能性があります。この問題は、結果セットをより小さなチャンクに分割することで回避できます。 たとえば、結果セットで 1,000 件のレコードが想定される場合は、 |
listEntitiesPageToken | 文字列 | 特定のページへのアクセスを可能にするページ識別子(トークン)。 ページトークンの値は、 |
listEntitiesSortByColumns | 文字列配列 | 結果セットの並べ替えに使用する列の名前。
|
出力パラメータ
次のテーブルに、さまざまなエンティティ オペレーションの出力パラメータを示します。
パラメータ名 | データ型 | 説明 |
---|---|---|
connectorOutputPayload | JSON | オペレーションの出力(JSON 形式)。 |
listEntitiesNextPageToken | 文字列 |
システムが生成したページの識別子。トークンは、結果セットの特定のページにアクセスするためのポインタと考えられます。
たとえば、 結果セットのページ数が多い場合は、For Each Loop タスクを使用してコネクタタスクを繰り返し呼び出し、データ マッピング タスクを使用して実行が完了するたびに |
エンティティ オペレーションのフィルタ句
タスクの入力として使用可能なフィルタ句変数を使用して、コネクタタスクによって処理されるレコードを制限できます。たとえば、削除オペレーションの場合、特定の orderId
を含むレコードを削除するフィルタ句を追加できます。
フィルタ句は、次のエンティティ オペレーションにのみ適用できます。
- List(リスト)
- Delete(削除)
- Update(更新)
これらのオペレーションのいずれかを選択すると、コネクタタスクの [Task Input] セクションに [Filter clause] フィールドが自動的に表示されます。
フィルタ句を追加
フィルタ句を追加する手順は、次のとおりです。
- デザイナーでコネクタタスク要素をクリックして、コネクタタスク構成ペインを表示します。
- [Task Input] セクションを開き、[filterClause(Connectors)] 文字列変数をクリックします。
[Configure Variable] ダイアログが表示されます。
- [デフォルト値] フィールドにフィルタ句(syntax 句の後)を入力します。
- [保存] をクリックします。
フィルタ句の構文と例
フィルタ句の形式は次のとおりです。
FIELD_NAME CONDITION FILTER_VALUE
例
OwnerId = '0053t000007941XAAQ'
PoNumber < 2345
OrderNumber = 00110 AND StatusCode = 'Draft'
TotalAmount > 2500
ShippingPostalCode = 94043 OR ShippingPostalCode = 77002
フィルタ句での変数の使用
フィルタ句でイ統合変数を直接使用することはできません。統合変数を使用する場合は、まずデータ マッピング タスクを構成して、統合変数とフィルタ句間のマッピングを作成する必要があります。次のテーブルに、統合変数と filterClause(Connectors)
変数間のマッピング例を示します。
入力 | 出力 |
---|---|
PRIMARY_KEY_ID = ' .CONCAT(INTEGRATION_VARIABLE) .CONCAT(') |
filterClause(Connectors) |
PRIMARY_KEY_ID = '
は入力行に値として入力されています。
インライン接続の作成
コネクタタスクを使用して、Integration Connectors で新しい接続を直接作成できます。
始める前に
接続の新規作成
Application Integration から新しい接続を作成するには、次の手順を行います。
- デザイナーで [コネクタ] タスク要素をクリックして、[コネクタ] タスク構成ペインを表示します。
- [コネクタを設定する] をクリックします。
[Connectors Task Editor] ページが表示されます。
- [リージョン] フィールドはスキップします。
- [接続] をクリックし、プルダウン メニューから [接続を作成] オプションを選択します。
- [接続を作成] ペインで、次の操作を行います。
- [ロケーション] ステップで、接続のロケーションを選択します。
- [リージョン] をクリックし、プルダウン リストからロケーションを選択します。
- [次へ] をクリックします。
- [接続の詳細] ステップで、接続の詳細を入力します。
- コネクタ: 作成するコネクタのタイプをプルダウン リストから選択します。サポートされているコネクタのリストについては、すべての Integration Connectors をご覧ください。
- コネクタのバージョン: プルダウン リストから、選択したコネクタタイプの使用可能なバージョンを選択します。
- 接続名: 接続インスタンスの名前を入力します。
- (オプション)接続インスタンスの [説明] を入力します。
- (オプション)接続インスタンスのログデータを保存するには、[Cloud Logging を有効にする] をオンにします。
- サービス アカウント: 必要なロールを持つサービス アカウントを選択します。
- (オプション)[詳細設定] をクリックして接続ノードの設定を構成します。
詳しくは、Integration Connectors のそれぞれの接続に関するドキュメントをご覧ください。
- (オプション)[ ラベルを追加] をクリックして Key-Value ペアの形式でラベルを接続に追加します。
- [次へ] をクリックします。
-
[認証] ステップで、接続の認証の詳細を入力します。
- このステップでは、作成された接続タイプに基づいた認証方法で入力されます。
接続タイプによって認証方法は異なります。詳細については、Integration Connectors のそれぞれの接続に関するドキュメントの認証を構成するのセクションをご覧ください。
- [次へ] をクリックします。
- このステップでは、作成された接続タイプに基づいた認証方法で入力されます。
- Review: 接続と認証の詳細を確認します。
- [作成] をクリックします。
- [ロケーション] ステップで、接続のロケーションを選択します。
おすすめの方法
- コネクタタスクに適用される使用量上限については、 使用量上限をご覧ください。
- 失敗した Connectors タスクのトラブルシューティング方法については、ログを使用してコネクタ障害のトラブルシューティングとトレースをご覧ください。
エラー処理方式
タスクのエラー処理方法では、一時的なエラーによってタスクが失敗した場合のアクションを指定します。エラー処理方式と、さまざまな種類のエラー処理方式の詳細については、エラー処理方法をご覧ください。