# mulesoft Google Bigquery Connector - Full Documentation # Anypoint Studio を使用した Google BigQuery Connector 1.0 の設定 Anypoint Studio (Studio) エディターは、Mule アプリケーション、プロパティ、および設定ファイルの設計と更新に役立ちます。 Studio でコネクタを追加および設定する手順は、次のとおりです。 1. [Mule プロジェクトを作成します](#create-mule-project)​。 2. [コネクタを Mule プロジェクトに追加します](#add-connector-to-project)​。 3. [コネクタのフローのソースを設定します](#configure-source)​。 4. [フローにコネクタの操作を追加します](#add-connector-operation)​。 5. [コネクタのグローバル要素を設定します](#configure-global-element)​。 6. [その他のコネクタ項目を設定します](#configure-other-fields)​。 [「アプリケーションログの表示」](#view-app-log)​で説明されているように、コネクタを実行するときに、リアルタイムでアプリケーションログを表示して問題を確認できます。 Studio で初めてコネクタを設定する場合は、​[「Anypoint Studio を使用したコネクタの設定」](https://docs.mulesoft.com/connectors/introduction/intro-config-use-studio)​を参照してください。このトピックを参照した後、コネクタ項目についての詳細情報が必要な場合は、​[「Google BigQuery Connector リファレンス」](https://docs.mulesoft.com/jp/google-bigquery-connector/1.0/google-bigquery-connector-reference)​を参照してください。 ## [](#create-mule-project)Mule プロジェクトを作成する Studio で、コネクタを追加および設定する新しい Mule プロジェクトを作成します。 1. Studio で、​**\[File (ファイル)\] > \[New (新規)\] > \[Mule Project (Mule プロジェクト)\]**​ を選択します。 2. Mule プロジェクトの名前を入力して、​**\[Finish (完了)\]**​ をクリックします。 ## [](#add-connector-to-project)コネクタを Mule プロジェクトに追加する Google BigQuery Connector を Mule プロジェクトに追加して、XML コードにコネクタの名前空間およびスキーマの場所を自動的に入力し、プロジェクトの ​`pom.xml`​ ファイルに必須の連動関係を追加します。 1. **\[Mule Palette (Mule パレット)\]**​ で、​**\[(X) Search in Exchange ((X) Exchange 内を検索)\]**​ をクリックします。 2. **\[Add Dependencies to Project (連動関係をプロジェクトに追加)\]**​ で、検索項目に「​`google bigquery`​」と入力します。 3. **\[Available modules (使用可能なモジュール)\]**​ で をクリックします。 4. **\[Add (追加)\]**​ をクリックします。 5. **\[Finish (完了)\]**​ をクリックします。 Studio でコネクタを Mule プロジェクトに追加しても、Studio ワークスペースの他のプロジェクトはそのコネクタを使用できません。 ## [](#configure-source)ソースの設定 ソースは、指定された条件が満たされたときにフローを開始します。 次のソースのいずれかを Google BigQuery Connector で使用するように設定できます。 - On Table Row ウォーターマークに基づいてテーブルのすべての行を返します。 - HTTP リスナー 設定されたホストとポートで要求を受信するたびにフローを開始する - スケジューラー 時間ベースの条件が満たされたときにフローを開始する たとえば、HTTP Listener ソースを設定する手順は、次のとおりです。 1. **\[Mule Palette (Mule パレット)\]**​ で、​**\[HTTP\] > \[Listener\]**​ を選択します。 2. **\[Listener\]**​ を Studio キャンバスにドラッグします。 3. **\[Listener (リスナー)\]**​ 設定画面で、必要に応じて ​**\[Display Name (表示名)\]**​ 項目の値を変更します。 4. **\[Path (パス)\]**​ 項目の値を指定します。 5. **\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックして、アプリケーション内の HTTP Listener ソースのすべてのインスタンスで使用できるグローバル要素を設定します。 6. **\[General (一般)\]**​ タブで、コネクタの接続情報を指定します。 7. **\[TLS\]**​ タブで、必要に応じてコネクタの TLS 情報を指定します。 8. **\[Advanced (詳細)\]**​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。 9. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。 10. **\[OK\]**​ をクリックします。 ## [](#add-connector-operation)フローにコネクタの操作を追加する フローにコネクタの操作を追加するときは、そのコネクタで実行するアクションを指定しています。 Google BigQuery Connector の操作を追加する手順は、次のとおりです。 1. **\[Mule Palette (Mule パレット)\]**​ で、​**\[Google BigQuery\]**​ を選択し、目的の操作を選択します。 2. その操作を Studio キャンバスの入力元の横にドラッグします。 ## [](#configure-global-element)コネクタのグローバル要素を設定する コネクタを設定する場合、アプリケーション内のそのコネクタのすべてのインスタンスで使用できるグローバル要素を設定します。グローバル要素を設定するには、コネクタが対象の Google BigQuery システムにアクセスするために必要な認証ログイン情報を指定する必要があります。Google BigQuery Connector では JWT と OAuth2 がサポートされています。 Google BigQuery Connector のグローバル要素を設定するには、次の手順に従います。 1. Studio キャンバスで操作を選択します。 2. 操作の ​**\[General (一般)\]**​ 設定画面で、​**\[Add (追加)\]**​ アイコンをクリックして、グローバル要素設定項目にアクセスします。 3. **\[General (一般)\]**​ タブの ​**\[Connection (接続)\]**​ で、設定する認証方式を選択します。 - [JWT](#jwt) - [OAuth2](#oauth2) ANT スタイルのプロパティプレースホルダーを含む設定ファイルを参照するか (推奨)、グローバル設定プロパティに認証ログイン情報を入力できます。プロパティプレースホルダーを使用する利点とその設定方法については、​[「Anypoint Connector 設定」](https://docs.mulesoft.com/connectors/introduction/intro-connector-configuration-overview)​を参照してください。 4. **\[Advanced (詳細)\]**​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。 5. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。 6. **\[OK\]**​ をクリックします。 ### [](#jwt)JWT **\[Global Element Properties (グローバル要素のプロパティ)\]**​ 画面の ​**\[General (一般)\]**​ タブで次の情報を入力し、JWT 認証を設定します。
項目 ユーザーアクション

名前

設定名を入力します。

Connection (接続)

[JWT]​ を選択します。

Private Key Id (非公開キー ID)

Google 接続アプリケーションの非公開キー ID を入力します。

Private Key (非公開キー)

Google 接続アプリケーションの非公開キーを入力します。

Issuer (発行者)

キーストアのパスワードを入力します。

次の画像は、JWT 認証の設定例を示しています。 ![\*\*\[Connection (接続)\]\* セクションでは \[JWT\]\* が選択され、\*\[General (一般)\]\* タブでは認証項目が入力されています。](_images/jwt-auth.png) 最初の項目は、コネクタが JWT 認証を使用することを指定する場所を示しています。2 番目の項目は、JWT 認証に関連する項目を含む ​**\[General (一般)\]**​ タブを示しています。 ### [](#oauth2)OAuth2 グローバル要素設定画面の ​**\[General (一般)\]**​ タブで次の情報を入力し、OAuth2 認証を設定します。
項目 ユーザーアクション

名前

設定名を入力します。

Connection (接続)

OAuth2​ を選択します。

Consumer Key (コンシューマーキー)

サービスプロバイダーに登録されている OAuth コンシューマーキーを入力します。

Consumer Secret (コンシューマーシークレット)

サービスプロバイダーに登録されている OAuth コンシューマーシークレットを入力します。

Listener Config (リスナー設定)

アクセストークンコールバックエンドポイントで要求をリスンする HTTP リスナーの設定を入力します。

Callback Path (コールバックパス)

アクセストークンコールバックエンドポイントのパスを入力します。

Authorize Path (認証パス)

OAuth ダンスをトリガーするローカル HTTP エンドポイントのパスを入力します。

次の画像は、OAuth2 認証の設定例を示しています。 ![\*\*\[Connection (接続)\]\* セクションでは \[OAuth2\]\* が選択され、\*\[General (一般)\]\* タブでは認証項目が入力されています。](_images/oauth2-auth.png) 最初の項目は、コネクタが OAuth2 認証を使用することを指定する場所を示しています。2 番目の項目は、OAuth2 認証に関連する項目を含む ​**\[General (一般)\]**​ タブを示しています。 ## [](#configure-other-fields)その他のコネクタ項目の設定 Google BigQuery Connector のグローバル要素を設定したら、コネクタの他の必須項目を設定します。必須項目は、使用するコネクタ操作によって異なります。 ## [](#view-app-log)アプリケーションログの表示 問題を確認するため、アプリケーションログを次の方法で表示できます。 - アプリケーションを Anypoint Platform から実行している場合、アプリケーションログ出力は Anypoint Studio のコンソールウィンドウに表示されます。 - コマンドラインから Mule を使用してアプリケーションを実行している場合、アプリケーションログ出力はオペレーティングシステムのコンソールに表示されます。 アプリケーションのログファイル (​`log4j2.xml`​) でログファイルパスがカスタマイズされていない場合、デフォルトの場所 ​`MULE_HOME/logs/.log`​ でアプリケーションログにアクセスすることもできます。ログパスは、アプリケーションログファイル ​`log4j2.xml`​ で設定できます。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Anypoint Studio を使用したコネクタの設定](https://docs.mulesoft.com/connectors/introduction/intro-config-use-studio) - [Google BigQuery Connector リファレンス](https://docs.mulesoft.com/jp/google-bigquery-connector/1.0/google-bigquery-connector-reference) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Anypoint Studio を使用した Google BigQuery Connector 1.1 の設定 Anypoint Studio (Studio) エディターは、Mule アプリケーション、プロパティ、および設定ファイルの設計と更新に役立ちます。 Studio でコネクタを追加および設定する手順は、次のとおりです。 1. [Mule プロジェクトを作成します](#create-mule-project)​。 2. [コネクタを Mule プロジェクトに追加します](#add-connector-to-project)​。 3. [コネクタのフローのソースを設定します](#configure-source)​。 4. [フローにコネクタの操作を追加します](#add-connector-operation)​。 5. [コネクタのグローバル要素を設定します](#configure-global-element)​。 6. [その他のコネクタ項目を設定します](#configure-other-fields)​。 [「アプリケーションログの表示」](#view-app-log)​で説明されているように、コネクタを実行するときに、リアルタイムでアプリケーションログを表示して問題を確認できます。 Studio で初めてコネクタを設定する場合は、​[「Anypoint Studio を使用したコネクタの設定」](https://docs.mulesoft.com/connectors/introduction/intro-config-use-studio)​を参照してください。このトピックを参照した後、コネクタ項目についての詳細情報が必要な場合は、​[「Google BigQuery Connector リファレンス」](https://docs.mulesoft.com/jp/google-bigquery-connector/1.1/google-bigquery-connector-reference)​を参照してください。 ## [](#create-mule-project)Mule プロジェクトを作成する Studio で、コネクタを追加および設定する新しい Mule プロジェクトを作成します。 1. Studio で、​**\[File (ファイル)\] > \[New (新規)\] > \[Mule Project (Mule プロジェクト)\]**​ を選択します。 2. Mule プロジェクトの名前を入力して、​**\[Finish (完了)\]**​ をクリックします。 ## [](#add-connector-to-project)コネクタを Mule プロジェクトに追加する Google BigQuery Connector を Mule プロジェクトに追加して、XML コードにコネクタの名前空間およびスキーマの場所を自動的に入力し、プロジェクトの ​`pom.xml`​ ファイルに必須の連動関係を追加します。 1. **\[Mule Palette (Mule パレット)\]**​ で、​**\[(X) Search in Exchange ((X) Exchange 内を検索)\]**​ をクリックします。 2. **\[Add Dependencies to Project (連動関係をプロジェクトに追加)\]**​ で、検索項目に「​`google bigquery`​」と入力します。 3. **\[Available modules (使用可能なモジュール)\]**​ で をクリックします。 4. **\[Add (追加)\]**​ をクリックします。 5. **\[Finish (完了)\]**​ をクリックします。 Studio でコネクタを Mule プロジェクトに追加しても、Studio ワークスペースの他のプロジェクトはそのコネクタを使用できません。 ## [](#configure-source)ソースの設定 ソースは、指定された条件が満たされたときにフローを開始します。 次のソースのいずれかを Google BigQuery Connector で使用するように設定できます。 - On Table Row ウォーターマークに基づいてテーブルのすべての行を返します。 - HTTP リスナー 設定されたホストとポートで要求を受信するたびにフローを開始する - スケジューラー 時間ベースの条件が満たされたときにフローを開始する たとえば、HTTP Listener ソースを設定する手順は、次のとおりです。 1. **\[Mule Palette (Mule パレット)\]**​ で、​**\[HTTP\] > \[Listener\]**​ を選択します。 2. **\[Listener\]**​ を Studio キャンバスにドラッグします。 3. **\[Listener (リスナー)\]**​ 設定画面で、必要に応じて ​**\[Display Name (表示名)\]**​ 項目の値を変更します。 4. **\[Path (パス)\]**​ 項目の値を指定します。 5. **\[Connector configuration (コネクタ設定)\]**​ 項目の横にあるプラス記号 (​**+**​) をクリックして、アプリケーション内の HTTP Listener ソースのすべてのインスタンスで使用できるグローバル要素を設定します。 6. **\[General (一般)\]**​ タブで、コネクタの接続情報を指定します。 7. **\[TLS\]**​ タブで、必要に応じてコネクタの TLS 情報を指定します。 8. **\[Advanced (詳細)\]**​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。 9. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。 10. **\[OK\]**​ をクリックします。 ## [](#add-connector-operation)フローにコネクタの操作を追加する フローにコネクタの操作を追加するときは、そのコネクタで実行するアクションを指定しています。 Google BigQuery Connector の操作を追加する手順は、次のとおりです。 1. **\[Mule Palette (Mule パレット)\]**​ で、​**\[Google BigQuery\]**​ を選択し、目的の操作を選択します。 2. その操作を Studio キャンバスの入力元の横にドラッグします。 ## [](#configure-global-element)コネクタのグローバル要素を設定する コネクタを設定する場合、アプリケーション内のそのコネクタのすべてのインスタンスで使用できるグローバル要素を設定します。グローバル要素を設定するには、コネクタが対象の Google BigQuery システムにアクセスするために必要な認証ログイン情報を指定する必要があります。Google BigQuery Connector では JWT と OAuth2 がサポートされています。 Google BigQuery Connector のグローバル要素を設定するには、次の手順に従います。 1. Studio キャンバスで操作を選択します。 2. 操作の ​**\[General (一般)\]**​ 設定画面で、​**\[Add (追加)\]**​ アイコンをクリックして、グローバル要素設定項目にアクセスします。 3. **\[General (一般)\]**​ タブの ​**\[Connection (接続)\]**​ で、設定する認証方式を選択します。 - [JWT](#jwt) - [OAuth2](#oauth2) ANT スタイルのプロパティプレースホルダーを含む設定ファイルを参照するか (推奨)、グローバル設定プロパティに認証ログイン情報を入力できます。プロパティプレースホルダーを使用する利点とその設定方法については、​[「Anypoint Connector 設定」](https://docs.mulesoft.com/connectors/introduction/intro-connector-configuration-overview)​を参照してください。 4. **\[Advanced (詳細)\]**​ タブで、必要に応じて再接続戦略を含む再接続情報を指定します。 5. **\[Test Connection (接続をテスト)\]**​ をクリックして、Mule が指定されたサーバーに接続できることを確認します。 6. **\[OK\]**​ をクリックします。 ### [](#jwt)JWT **\[Global Element Properties (グローバル要素のプロパティ)\]**​ 画面の ​**\[General (一般)\]**​ タブで次の情報を入力し、JWT 認証を設定します。
項目 ユーザーアクション

名前

設定名を入力します。

Connection (接続)

[JWT]​ を選択します。

Private Key Id (非公開キー ID)

Google 接続アプリケーションの非公開キー ID を入力します。

Private Key (非公開キー)

Google 接続アプリケーションの非公開キーを入力します。

Issuer (発行者)

キーストアのパスワードを入力します。

次の画像は、JWT 認証の設定例を示しています。 ![\[Connection (接続)\] セクションでは \[JWT\] が選択され、\[General (一般)\] タブでは認証項目が入力されています。](_images/jwt-auth.png) 最初の項目は、コネクタが JWT 認証を使用することを指定する場所を示しています。2 番目の項目は、JWT 認証に関連する項目を含む ​**\[General (一般)\]**​ タブを示しています。 ### [](#oauth2)OAuth2 Unresolved include directive in modules/ROOT/pages/google-bigquery-connector-studio.adoc - include::connectors::partial$oauth2-description.adoc\[\] グローバル要素設定画面の ​**\[General (一般)\]**​ タブで次の情報を入力し、OAuth2 認証を設定します。
項目 ユーザーアクション

名前

設定名を入力します。

Connection (接続)

OAuth2​ を選択します。

Consumer Key (コンシューマーキー)

サービスプロバイダーに登録されている OAuth コンシューマーキーを入力します。

Consumer Secret (コンシューマーシークレット)

サービスプロバイダーに登録されている OAuth コンシューマーシークレットを入力します。

Listener Config (リスナー設定)

アクセストークンコールバックエンドポイントで要求をリスンする HTTP リスナー設定を入力します。

Callback Path (コールバックパス)

アクセストークンコールバックエンドポイントのパスを入力します。

Authorize Path (認証パス)

OAuth ダンスをトリガーするローカル HTTP エンドポイントのパスを入力します。

次の画像は、OAuth2 認証の設定例を示しています。 ![\[Connection (接続)\] セクションでは \[OAuth2\] が選択され、\[General (一般)\] タブでは認証項目が入力されています。](_images/oauth2-auth.png) 最初の項目は、コネクタが OAuth2 認証を使用することを指定する場所を示しています。2 番目の項目は、OAuth2 認証に関連する項目を含む ​**\[General (一般)\]**​ タブを示しています。 ## [](#configure-other-fields)その他のコネクタ項目の設定 Google BigQuery Connector のグローバル要素を設定したら、コネクタの他の必須項目を設定します。必須項目は、使用するコネクタ操作によって異なります。 ## [](#view-app-log)アプリケーションログの表示 問題を確認するため、アプリケーションログを次の方法で表示できます。 - アプリケーションを Anypoint Platform から実行している場合、アプリケーションログ出力は Anypoint Studio のコンソールウィンドウに表示されます。 - コマンドラインから Mule を使用してアプリケーションを実行している場合、アプリケーションログ出力はオペレーティングシステムのコンソールに表示されます。 アプリケーションのログファイル (​`log4j2.xml`​) でログファイルパスがカスタマイズされていない場合、デフォルトの場所 ​`MULE_HOME/logs/.log`​ でアプリケーションログにアクセスすることもできます。ログパスは、アプリケーションログファイル ​`log4j2.xml`​ で設定できます。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Anypoint Studio を使用したコネクタの設定](https://docs.mulesoft.com/connectors/introduction/intro-config-use-studio) - [Google BigQuery Connector リファレンス](https://docs.mulesoft.com/jp/google-bigquery-connector/1.1/google-bigquery-connector-reference) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Google BigQuery Connector 1.0 Google BigQuery 用 Anypoint Connector (Google BigQuery Connector) では、Google BigQuery とオンプレミスまたはクラウドのサードパーティアプリケーション間でデータを同期し、ビジネスプロセスを自動化します。 互換性と修正された問題については、「Google BigQuery Connector リリースノート」を参照してください。 ## [](#始める前に)始める前に このコネクタを使用するには、以下に精通している必要があります。 - Google BigQuery API - Anypoint Connector - Mule Runtime Engine (Mule) - Mule フローの要素とグローバル要素 - Anypoint Studio を使用した Mule アプリケーションの作成方法 アプリケーションを作成する前に、以下が必要です。 - Google BigQuery の対象リソースにアクセスするためのログイン情報 - Anypoint Platform - Anypoint Studio バージョン 7.3.5 以降 ## [](#コネクタの一般的なユースケース)コネクタの一般的なユースケース 次に、Google BigQuery Connector の一般的なユースケースを示します。 - ログとイベントデータコレクションを使用して問題を分析する - Google BigQuery のデータを挿入、更新、削除する - Google BigQuery でクエリを実行する これらのユースケースの例については、​[「Google BigQuery Connector の例」](https://docs.mulesoft.com/jp/google-bigquery-connector/1.0/google-bigquery-connector-examples)​を参照してください。 ## [](#接続種別)接続種別 Google BigQuery 接続では、次の認証種別を使用します。 - JWT 接続 認証でトークンを使用します。 - OAuth2 接続 サービスアカウント認証を使用します。 認証種別の設定についての詳細は、​[「コネクタのグローバル要素の設定」](https://docs.mulesoft.com/jp/google-bigquery-connector/1.0/google-bigquery-connector-studio#configure-global-element)​を参照してください。 ## [](#次のステップ)次のステップ 前提条件を満たしたら、​[Anypoint Studio](https://docs.mulesoft.com/jp/google-bigquery-connector/1.0/google-bigquery-connector-studio)​ でアプリケーションを作成してコネクタを設定できます。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Exchange を使用したコネクタ、テンプレート、およびサンプルの検出](https://docs.mulesoft.com/connectors/introduction/intro-use-exchange) - [Google BigQuery Connector リファレンス](https://docs.mulesoft.com/jp/google-bigquery-connector/1.0/google-bigquery-connector-reference) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Google BigQuery Connector 1.0 - XML と Maven のサポート XML で Mule アプリケーションを手動でコーディングすることもできますが、Anypoint Studio を使用した方が効率的です。 - Mule Runtime Engine (Mule) アプリケーションを (Anypoint Studio の XML エディターまたはテキストエディターから) 手動でコーディングする場合、参照ステートメントを XML Mule フローと Apache Maven ​`pom.xml`​ ファイルの両方に追加することで、アプリケーションからコネクタにアクセスできます。 - Studio でコネクタを追加すると、Studio は自動的に XML コードにコネクタの名前空間およびスキーマの場所を入力し、​`pom.xml`​ ファイルに連動関係を追加します。 ## [](#コネクタの名前空間の追加)コネクタの名前空間の追加 次のコードを設定 XML のヘッダーの ​`mule`​ タグ内に貼り付けます。 ```xml http://www.mulesoft.org/schema/mule/google-bigquery http://www.mulesoft.org/schema/mule/google-bigquery/current/mule-google-bigquery.xsd ``` 次の例は、XML 内に名前空間ステートメントが配置される方法を示しています。 ```xml ``` ## [](#pom-ファイルの連動関係の追加)POM ファイルの連動関係の追加 Apache Maven ​`pom.xml`​ ファイルは Anypoint Studio によって生成され、Mule アプリケーションの連動関係が含まれます。Mule アプリケーションを手動でコーディングする場合、次の XML スニペットを ​`pom.xml`​ ファイルに含めてこのコネクタにアクセスできるようにします。 ```xml com.mulesoft.connectors mule4-google-bigquery x.x.x mule-plugin ``` ``​ を使用しているコネクタに対応するバージョンに置き換えます。 最新の ​`pom.xml`​ ファイル情報を取得する手順は、次のとおりです。 1. [Anypoint Exchange](https://www.mulesoft.com/exchange/)​ に移動します。 2. Exchange で、​**\[Login (ログイン)\]**​ をクリックし、Anypoint Platform のユーザー名とパスワードを指定します。 3. Exchange で、「​`google bigquery`​」を検索します。 4. コネクタを選択します。 5. 画面の右上付近にある ​**\[Dependency Snippets (連動関係スニペット)\]**​ をクリックします。 ## [](#次のステップ)次のステップ 名前空間および ​`pom.xml`​ ファイルを完了したら、​[例](https://docs.mulesoft.com/jp/google-bigquery-connector/1.0/google-bigquery-connector-examples)​を試すことができます。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Google BigQuery Connector 1.0 の例 Google BigQuery Connector の Mule フローの例を次にいくつか示します。 - [ジョブの取得](#get-job) - [ジョブの挿入](#insert-job) - [ジョブの削除](#delete-job) - [クエリ結果の取得](#get-query-result) - [ジョブのキャンセル](#cancel-job) - [ジョブのリスト](#list-jobs) - [クエリ](#query) - [On Table Row の使用](#on-table-row) - [認証](#authorize) - [HTML フォームの表示](#html-form) ## [](#始める前に)始める前に - Java 8 または 11 - Anypoint Studio 7.5 以降 - Mule Runtime Engine (Mule) 4.3.0 以降 - DataWeave - Google API の OAuth ログイン情報 ## [](#接続の設定)接続の設定 接続を保護するには、OAuth 接続項目の値を指定する必要があります。次の手順を実行します。 - [接続の設定ファイルを作成する](#create-config-file)​。 - [接続のグローバル要素を設定する](#configure-conn)​。 - [プロパティファイルのグローバル要素を設定する](#configure-global)​。 ### [](#create-config-file)接続の設定ファイルを作成する 接続のプロパティが含まれる設定ファイルを作成します。 1. `/src/main/resources/`​ フォルダー内に ​`mule-app.properties`​ という名前のファイルを作成します。 2. `mule-app.properties`​ ファイルに、次のような接続の一連のプロパティを作成します。括弧で囲まれたテキスト (括弧を含む) を各自の設定の適切な値に置き換えます。 config.consumerKey= config.consumerSecret= これは、選択した接続設定によって異なる場合があります。 プロパティファイルの作成についての詳細は、​[「プロパティプレースホルダーの設定」](https://docs.mulesoft.com/mule-runtime/latest/mule-app-properties-to-configure)​を参照してください。 ### [](#configure-conn)接続のグローバル要素を設定する 接続のグローバル要素を設定します。 1. 新しい Mule プロジェクトを作成します。 2. **\[Mule Palette (Mule パレット)\]**​ ビューで、​**\[Search in Exchange (Exchange 内を検索)\]**​ をクリックして「​`google bigquery`​」と入力します。 3. **\[Google BigQuery Connector\]**​ を ​**\[Selected modules (選択済みモジュール)\]**​ セクションに追加し、​**\[Finish (完了)\]**​ をクリックします。 4. **\[Global Elements (グローバル要素)\]**​ タブをクリックし、​**\[Create (作成)\]**​ をクリックします。 5. **\[Connector Configuration (コネクタ設定)\] > \[Google BigQuery Config (Google BigQuery 設定)\]**​ を選択し、​**\[OK\]**​ をクリックします。 6. JWT または OAuth2 を設定するための値を入力します。 7. **\[Test Connection (接続をテスト**​)\] ボタンをクリックして、Google API と接続されていることを確認します。ポップアップに成功メッセージが表示されます。 8. **\[OK\]**​ をクリックします。 9. **\[Global Element Configuration (グローバル要素設定)\]**​ で HTTPS リスナー設定を開きます。 10. **\[TLS\]**​ タブをクリックし、\[TLS Configuration (TLS 設定)\] > \[Edit inline (インライン編集)\] を選択します。 11. 生成されたキーストアの詳細を使用して ​**\[Key Store Configuration (キーストア設定)\]**​ を指定し、この設定で HTTPS を有効にします。 12. **\[OK\]**​ をクリックします。 ### [](#configure-global)プロパティファイルのグローバル要素を設定する `mule-app.properties`​ ファイルのグローバル要素を設定して、Mule がその場所を認識できるようにします。 1. **\[Global Elements (グローバル要素)\]**​ タブをクリックし、​**\[Create (作成)\]**​ をクリックします。 2. **\[Choose Global Type (グローバル種別の選択)\]**​ ダイアログで、​**\[Configuration properties (設定プロパティ)\]**​ を選択し、​**\[OK\]**​ をクリックします。 3. **\[File (ファイル)\]**​ 項目に「​`mule.app.properties`​」と入力します。 4. **\[OK\]**​ をクリックします。 ## [](#get-job)ジョブの取得 この Mule フローでは、指定されたジョブ ID からジョブを取得します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Get Job**​ ジョブを取得します。 次の値を入力します。
項目 値

Job id (ジョブ ID)

attributes.queryParams.jobId

- **Logger**​ **Get Job**​ 操作からの HTTP 応答を表示します。 ![Get Job 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/get-job.png) ### [](#この例の-xml)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#insert-job)ジョブの挿入 この Mule フローでは、入力設定を使用してジョブを挿入します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Insert Job**​ ジョブを挿入します。 次の値を入力します。
項目 値

Job values content (ジョブ値のコンテンツ)

payload

- **Logger**​ **Insert Job**​ 操作からの HTTP 応答を表示します。 ![Insert Job 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/insert-job.png) ### [](#この例の-xml-2)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-2)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#delete-job)ジョブの削除 この Mule フローでは、指定されたジョブ ID からジョブを削除します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Delete Job**​ ジョブを削除します。 次の値を入力します。
項目 値

Job id (ジョブ ID)

attributes.queryParams.jobId

- **Logger**​ **Delete Job**​ 操作からの HTTP 応答を表示します。 ![Delete Job 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/delete-job.png) ### [](#この例の-xml-3)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-3)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#get-query-result)クエリ結果の取得 この Mule フローでは、クエリの結果を取得します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Get Query Results**​ クエリの結果を取得します。 次の値を入力します。
項目 値

Job id (ジョブ ID)

attributes.queryParams.jobId

Start Index (開始インデックス)

0

Max Results (最大結果数)

25

- **Logger**​ **Get Query Result**​ 操作からの HTTP 応答を表示します。 ![Get Query Result 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/get-query-result.png) ### [](#この例の-xml-4)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-4)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#cancel-job)ジョブのキャンセル この Mule フローでは、指定されたジョブ ID からジョブをキャンセルします。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Cancel Job**​ ジョブをキャンセルします。 次の値を入力します。
項目 値

Job id (ジョブ ID)

attributes.queryParams.jobId

Content-Type (コンテンツタイプ)

application/json

- **Logger**​ **Cancel Job**​ 操作からの HTTP 応答を表示します。 ![Cancel Job 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/cancel-job.png) ### [](#この例の-xml-5)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-5)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#list-jobs)ジョブのリスト この Mule フローでは、プロジェクトからジョブを取得します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **List Jobs**​ ジョブをリストします。 次の値を入力します。
項目 値

Content-Type (コンテンツタイプ)

application/json

Max Results (最大結果数)

30

Pretty Print (プリティプリント)

False (Default)

- **Logger**​ **List Jobs**​ 操作からの HTTP 応答を表示します。 ![List Jobs 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/list-jobs.png) ### [](#この例の-xml-6)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-6)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#query)クエリ この Mule フローでは、クエリジョブ値で指定されたクエリを実行します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Query**​ クエリを実行します。 次の値を入力します。
項目 値

Query values content (クエリ値のコンテンツ)

%dw 2.0
output application/json
---

payload
- **Logger**​ **Query**​ 操作からの HTTP 応答を表示します。 ![Query 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/query.png) ### [](#この例の-xml-7)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-7)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#on-table-row)On Table Row の使用 この Mule フローでは、​**On Table Row**​ ソースを使用します。 この例では、次の操作を使用します。 - **On Table Row**​ ウォーターマークに基づいてテーブルのすべての行を返します。 次の値を入力します。
項目 値

Scheduling Strategy (スケジュール戦略)

Fixed Frequency

Frequency (頻度)

1000

Start delay (開始遅延)

0

Time unit (時間単位)

MILLISECONDS (Default)

Dataset name (データセット名)

test124

Table name (テーブル名)

table_data

Watermark column (ウォーターマーク列)

id

Since (以降)

1

Column id (列 ID)

id

- **Logger**​ **On Table Row**​ ソースからの HTTP 応答を表示します。 - **Transform Message**​ **On Table Row**​ 操作の結果を JSON 形式で出力します。 %dw 2.0 output application/json --- payload ![On Table Row ソースの Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/on-table-row.png) ### [](#この例の-xml-8)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-8)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#authorize)認証 この Mule フローでは、接続を認証します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Request**​ HTTP サービスをコンシュームします。 次の値を入力します。
項目 値

Method (メソッド)

GET (Default)

Path (パス)

/authorize?resourceOwnerId=demo

Body (本文)

payload

- **Logger**​ **Request**​ 操作からの HTTP 応答を表示します。 ![Request 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/authorize.png) ### [](#この例の-xml-9)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-9)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#html-form)HTML フォームの表示 この Mule フローでは、HTML フォームを表示します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Parse Template**​ テンプレートを処理します。 次の値を入力します。
項目 値

Location (場所)

index.html

![Parse Template コンポーネントの Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.0/_images/html-form.png) ### [](#この例の-xml-10)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-10)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Google BigQuery Connector 1.0 リファレンス ## [](#設定)設定 * * * ### [](#Config)Configuration (設定) #### [](#パラメーター)パラメーター
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

Connection (接続)

この設定の接続種別。

x

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

30

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

SECONDS

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

AUTO

Name (名前)

String (文字列)

この設定の参照に使用される ID。

x

Expiration Policy (有効期限ポリシー)

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。

#### [](#接続種別)接続種別 ##### [](#Config_Jwt)JWT 接続 ###### [](#パラメーター-2)パラメーター
名前 型 説明 デフォルト値 必須

Project Id (プロジェクト ID)

String (文字列)

プロジェクト ID。

Base Uri (ベース URI)

String (文字列)

パラメーターのベース URI。各インスタンスまたはテナントが独自のベース URI を取得します。

https://bigquery.googleapis.com/bigquery/v2

Default Headers (デフォルトヘッダー)

Object (オブジェクト)

要求に含めるデフォルトヘッダー。

Query Parameters (クエリパラメーター)

Object (オブジェクト)

要求に含めるクエリパラメーター。

Connection Timeout (接続タイムアウト)

Number (数値)

リモートサーバーへの接続を確立するときのコネクタの待機時間。この時間を経過するとタイムアウトします。

30

Connection Timeout Unit (接続タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection Timeout (接続タイムアウト)]​ 項目の時間単位。

SECONDS

Use Persistent Connections (永続接続を使用)

Boolean (ブール)

永続接続を使用するかどうかを示します。

  • true​

    Mule は永続接続を使用します。

  • false​

    Mule は最初の要求が完了すると接続を閉じます。

true

Max Connections (最大接続数)

Number (数値)

バックエンドに対して開く接続の最大数。HTTP 要求は、複数の接続を介して並行して送信されます。この値の設定が高すぎると、レイテンシーに影響し、スループットを高めることなく追加リソースがコンシュームされる可能性があります。

-1

Connection Idle Timeout (接続アイドルタイムアウト)

Number (数値)

永続接続が有効になっている場合、接続が Mule によって閉じられるまでアイドル状態を維持できる時間。

30

Connection Idle Timeout Unit (接続アイドルタイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection Idle Timeout (接続アイドルタイムアウト)]​ 項目の時間単位。

SECONDS

Proxy Config (プロキシ設定)

アウトバウンド接続のプロキシを設定します。

Stream Response (応答のストリーミング)

Boolean (ブール)

この値が ​true​ の場合、Mule は受信した応答をストリーミングします。

false

Response Buffer Size (応答バッファサイズ)

Number (数値)

HTTP 応答が保存されるバッファのサイズ (バイト)。

-1

Name app (アプリケーションの名前付け)

String (文字列)

パラメーターアプリケーション名。

appName1

Private Key Id (非公開キー ID)

String (文字列)

Google 接続アプリケーションの非公開キー ID。

x

Private Key (非公開キー)

String (文字列)

Google 接続アプリケーションの非公開キー。

x

Issuer (発行者)

String (文字列)

クライアントメール。

x

Audience Url (オーディエンス URL)

String (文字列)

オーディエンスは対象オーディエンスとして認証サーバーを識別します。認証サーバーは、トークンの対象オーディエンスであることを確認する必要があります。オーディエンス値に認証サーバーの URL を使用します: https://bigquery.googleapis.com/​。

https://bigquery.googleapis.com/

Token Timeout (トークンタイムアウト)

Number (数値)

トークンのタイムアウト。

3600

Token Timeout Unit (トークンタイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Token Timeout (トークンタイムアウト)]​ 項目の時間単位。

SECONDS

Protocol (プロトコル)

Enumeration (列挙)。次のいずれかになります。 HTTP HTTPS

通信に使用するプロトコル。

HTTP

TLS Configuration (TLS 設定)

TLS

TLS 設定。

Reconnection (再接続)

アプリケーションのデプロイ時に、関連する再接続戦略をすべて実行した後、接続テストに合格しない場合の処理:

  • true​

    デプロイメントの失敗を許可します。

  • false​

    接続テストの結果を無視します。

##### [](#Config_Oauth2)OAuth2 接続 ###### [](#パラメーター-3)パラメーター
名前 型 説明 デフォルト値 必須

Project Id (プロジェクト ID)

String (文字列)

プロジェクト ID。

Base Uri (ベース URI)

String (文字列)

パラメーターのベース URI。各インスタンスまたはテナントが独自のパラメーターベース URI を取得します。

https://bigquery.googleapis.com/bigquery/v2

Default Headers (デフォルトヘッダー)

Object (オブジェクト)

要求に含めるデフォルトヘッダー。

Query Parameters (クエリパラメーター)

Object (オブジェクト)

要求に含めるクエリパラメーター。

Connection Timeout (接続タイムアウト)

Number (数値)

リモートサーバーへの接続を確立するときのコネクタの待機時間。この時間を経過するとタイムアウトします。

30

Connection Timeout Unit (接続タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection Timeout (接続タイムアウト)]​ 項目の時間単位。

SECONDS

Use Persistent Connections (永続接続を使用)

Boolean (ブール)

永続接続を使用するかどうかを示します。

  • true​

    Mule は永続接続を使用します。

  • false​

    Mule は最初の要求が完了すると接続を閉じます。

true

Max Connections (最大接続数)

Number (数値)

バックエンドに対して開く接続の最大数。HTTP 要求は、複数の接続を介して並行して送信されます。この値の設定が高すぎると、レイテンシーに影響し、スループットを高めることなく追加リソースがコンシュームされる可能性があります。

-1

Connection Idle Timeout (接続アイドルタイムアウト)

Number (数値)

永続接続が有効になっている場合、接続が Mule によって閉じられるまでアイドル状態を維持できる時間。

30

Connection Idle Timeout Unit (接続アイドルタイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection Idle Timeout (接続アイドルタイムアウト)]​ 項目の時間単位。

SECONDS

Proxy Config (プロキシ設定)

アウトバウンド接続のプロキシを設定します。

Stream Response (応答のストリーミング)

Boolean (ブール)

この値が ​true​ の場合、Mule は受信した応答をストリーミングします。

false

Response Buffer Size (応答バッファサイズ)

Number (数値)

HTTP 応答が保存されるバッファのサイズ (バイト)。

-1

Name app (アプリケーションの名前付け)

String (文字列)

パラメーターアプリケーション名。

appName1

Access_type

String (文字列)

ユーザーがブラウザーにいない場合にアクセストークンを更新するかどうかを示します。

* online (オンライン) + アクセストークンを取得します。

* offline (オフライン) + 更新トークンとアクセストークンを取得します。

offline (オフライン)

Protocol (プロトコル)

Enumeration (列挙)。次のいずれかになります。

  • HTTP

  • HTTPS

通信に使用するプロトコル。

HTTP

TLS Configuration (TLS 設定)

TLS

TLS を設定します。HTTPS プロトコルを使用する場合、TLS を設定する必要があります。

Reconnection (再接続)

アプリケーションのデプロイ時に、関連する再接続戦略をすべて実行した後、接続テストに合格しない場合の処理:

  • true​

    デプロイメントの失敗を許可します。

  • false​

    接続テストの結果を無視します。

Consumer Key (コンシューマーキー)

String (文字列)

サービスプロバイダーに登録されている OAuth コンシューマーキー。

x

Consumer Secret (コンシューマーシークレット)

String (文字列)

サービスプロバイダーに登録されている OAuth コンシューマーシークレット。

x

Authorization Url (認証 URL)

String (文字列)

サービスプロバイダーの認証エンドポイントの URL。

https://accounts.google.com/o/oauth2/auth

Access Token Url (アクセストークン URL)

String (文字列)

サービスプロバイダーのアクセストークンエンドポイントの URL。

https://oauth2.googleapis.com/token

Scopes (スコープ)

String (文字列)

OAuth ダンス時に要求する Oauth スコープ。この値のデフォルトはアノテーションのスコープです。

https://www.googleapis.com/auth/bigquery

Resource Owner Id (リソースオーナー ID)

String (文字列)

認証コード許可種別で使用するリソースオーナー ID。

Before (前)

String (文字列)

OAuth ダンスを開始する直前に実行するフローの名前。

After (後)

String (文字列)

アクセストークンを受信した直後に実行するフローの名前。

Listener Config (リスナー設定)

String (文字列)

アクセストークンコールバックエンドポイントで要求をリスンする HTTP リスナー設定。

x

Callback Path (コールバックパス)

String (文字列)

アクセストークンコールバックエンドポイントのパス。

x

Authorize Path (認証パス)

String (文字列)

OAuth ダンスをトリガーするローカル HTTP エンドポイントのパス。

x

External Callback Url (外部コールバック URL)

String (文字列)

コールバックエンドポイントがプロキシの背後にあるか、間接 URL でアクセスする場合にコールバックエンドポイントにアクセスするために OAuth プロバイダーで使用する URL。

Object Store (オブジェクトストア)

String (文字列)

各リソースオーナーのデータを保存するオブジェクトストアを設定します。設定されていない場合、Mule ではデフォルトのオブジェクトストアが使用されます。

## [](#サポートされている操作)サポートされている操作 - [Cancel Job](#CancelJob) - [Delete Job](#DeleteJob) - [Get Job](#GetJob) - [Get Query Results](#GetQueryResults) - [Insert Job](#InsertJob) - [List Jobs](#ListJobs) - [Query](#Query) - [Unauthorize](#Unauthorize) ## [](#関連付けられたソース)関連付けられたソース - [On Table Row](#OnTableRow) ## [](#操作)操作 ### [](#CancelJob)Cancel Job `` ジョブをキャンセルします。この操作では、/project/{projectId}/jobs/{jobId}/cancel エンドポイントに対する HTTP POST 要求を行います。 #### [](#パラメーター-4)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job id (ジョブ ID)

String (文字列)

ジョブ ID。

x

Content Type (コンテンツタイプ)

String (文字列)

コンテンツタイプ。

application/json

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力)出力

型

Any (任意)

Attributes Type (属性型)

#### [](#次の設定の場合)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:RETRY\_EXHAUSTED - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#DeleteJob)Delete Job `` ジョブを削除します。この操作では、/project/{projectId}/job/{jobId} エンドポイントに対する HTTP DELETE 要求を行います。 #### [](#パラメーター-5)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job id (ジョブ ID)

String (文字列)

ジョブ ID。

x

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#次の設定の場合-2)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-2)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:RETRY\_EXHAUSTED - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#GetJob)Get Job `` ジョブを取得します。この操作では、/project/{projectId}/jobs/{jobId} エンドポイントに対する HTTP GET 要求を行います。 #### [](#パラメーター-6)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job id (ジョブ ID)

String (文字列)

ジョブ ID。

x

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-2)出力

型

Any (任意)

Attributes Type (属性型)

#### [](#次の設定の場合-3)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-3)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:RETRY\_EXHAUSTED - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#GetQueryResults)Get Query Results `` クエリの結果を取得します。この操作では、/projects/{projectId}/queries/{jobId} に対する HTTP GET 要求を行います。 #### [](#パラメーター-7)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job id (ジョブ ID)

String (文字列)

ジョブ ID。

Start Index (開始インデックス)

Number (数値)

開始行の開始値 0 のインデックス。

0

Max Results (最大結果数)

Number (数値)

ページごとに返されるコメントの最大数。

30

Page Token (ページトークン)

String (文字列)

次のページで前のリスト要求を続行するためのトークン。このパラメーターは前の応答からの ​nextPageToken​ の値に設定します。

Location (場所)

String (文字列)

ジョブの地理的場所。

Time out (タイムアウト)

String (文字列)

クエリの完了を待機する最大時間 (ミリ秒) を指定します。

Output Mime Type (出力 MIME タイプ)

String (文字列)

この操作で出力されるペイロードの MIME タイプ。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-3)出力

型

Any の配列

#### [](#次の設定の場合-4)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-4)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#InsertJob)Insert Job `` ジョブを挿入します。この操作では、/project/{projectId}/jobs エンドポイントに対する HTTP POST 要求を行います。 #### [](#パラメーター-8)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job Values Content (ジョブ値のコンテンツ)

Any (任意)

ジョブ値のコンテンツ。

x

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-4)出力

型

Any (任意)

Attributes Type (属性型)

#### [](#次の設定の場合-5)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-5)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:RETRY\_EXHAUSTED - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#ListJobs)List Jobs `` ジョブをリストします。この操作では、/projects/{projectId}/jobs エンドポイントに対する HTTP GET 要求を行います。 #### [](#パラメーター-9)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Content Type (コンテンツタイプ)

String (文字列)

コンテンツタイプ。

application/json

Max Results (最大結果数)

Number (数値)

ページごとに返されるコメントの最大数。

30

Pretty Print (プリティプリント)

Boolean (ブール)

インデントと改行を含む応答を返します。

false

Page Token (ページトークン)

String (文字列)

次のページで前のリスト要求を続行するためのトークン。このパラメーターは前の応答からの ​nextPageToken​ の値に設定します。

Quota User (クォータユーザー)

String (文字列)

クォータの目的のユーザーを表す不透明な文字列。40 文字までです。

User Ip (ユーザー IP)

String (文字列)

非推奨になりました。代わりに ​[Quota User (クォータユーザー)]​ を使用します。

fields (項目)

String (文字列)

部分的な応答に含める項目を指定するセレクター。

Min Created Time (最小作成時刻)

String (文字列)

結果コメントの ​modifiedTime​ の最小値 (RFC 3339 日時)。

Max Created Time (最大作成時刻)

String (文字列)

結果コメントの ​modifiedTime​ の最大値 (RFC 3339 日時)。

Output Mime Type (出力 MIME タイプ)

String (文字列)

この操作で出力されるペイロードの MIME タイプ。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-5)出力

型

Any の配列

#### [](#次の設定の場合-6)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-6)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#Query)Query `` クエリを実行します。この操作では、/projects/{projectId}/queries エンドポイントに対する HTTP POST クエリ要求を行います。 #### [](#パラメーター-10)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Query Values Content (クエリ値のコンテンツ)

Any (任意)

クエリ値のコンテンツ。

x

Output Mime Type (出力 MIME タイプ)

String (文字列)

この操作で出力されるペイロードの MIME タイプ。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-6)出力

型

Any の配列

#### [](#次の設定の場合-7)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-7)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#Unauthorize)Unauthorize `` 特定のリソースオーナー ID のアクセストークン情報をすべて削除して、認証ダンスを再度実行しない限り、そのユーザー向けの操作を実行できないようにします。 #### [](#パラメーター-11)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Resource Owner Id (リソースオーナー ID)

String (文字列)

アクセスを無効にするリソースオーナーの ID。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

#### [](#次の設定の場合-8)次の設定の場合 - [Configuration (設定)](#Config) ## [](#ソース)ソース ### [](#OnTableRow)On Table Row `` ウォーターマークに基づいてテーブルのすべての行を返します。 #### [](#パラメーター-12)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Primary Node Only (プライマリノードのみ)

Boolean (ブール)

クラスターでの Mule インスタンスの実行時、このソースをプライマリノード上でのみ実行するかどうかを決定します。

Scheduling Strategy (スケジュール戦略)

scheduling-strategy

ポーリングをトリガーするスケジューラーを設定します。

x

Redelivery Policy (再配信ポリシー)

同じメッセージの再配信を処理するためのポリシーを定義します。

Dataset Name (データセット名)

String (文字列)

選択元のテーブルの名前。

x

Table Name (テーブル名)

String (文字列)

選択元のテーブルの名前。

x

Watermark Column (ウォーターマーク列)

String (文字列)

ウォーターマークに使用する列の名前。この列から取得された値を使用して次のポーリングのコンテンツが絞り込まれるため、より大きなウォーターマーク値を持つ行のみが処理されます。

Since (以降)

String (文字列)

ウォーターマークとして使用する値。

Column Id (列 ID)

String (文字列)

行 ID とみなす列の名前。このパラメーターを指定することで、同じ行が同時ポーリングによって 2 回処理されないようになります。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-7)出力

型

String (文字列)

Attributes Type (属性型)

#### [](#次の設定の場合-9)次の設定の場合 - [Configuration (設定)](#Config) ## [](#型)型 ### [](#Proxy)Proxy (プロキシ) アウトバウンド接続のプロキシを設定します。
項目 型 説明 デフォルト値 必須

Host (ホスト)

String (文字列)

プロキシサーバーのホスト名または IP アドレス。

x

Port (ポート)

Number (数値)

プロキシサーバーのポート。

x

Username (ユーザー名)

String (文字列)

プロキシサーバーに対して認証するユーザー名。

Password (パスワード)

String (文字列)

プロキシサーバーに対して認証するパスワード。

Non Proxy Hosts (非プロキシホスト)

String (文字列)

プロキシを使用してはならないホストのカンマ区切りリスト。

### [](#Tls)TLS Mule アプリケーションのセキュアな通信を提供するように TLS を設定します。
項目 型 説明 デフォルト値 必須

Enabled Protocols (有効化されたプロトコル)

String (文字列)

このコンテキストで有効化されたプロトコルのカンマ区切りリスト。

Enabled Cipher Suites (有効化された暗号化スイート)

String (文字列)

このコンテキストで有効化された暗号化スイートのカンマ区切りリスト。

トラストストア

TLS トラストストアを設定します。

Key Store (キーストア)

TLS キーストアを設定します。

Revocation Check (取り消し確認)

取り消し確認メカニズムを設定します。

### [](#TrustStore)Truststore (トラストストア) TLS 用のトラストストアを設定します。
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

トラストストアへのパス。Mule では、現在のクラスパスとファイルシステムへの相対的なパスを解決します。

Password (パスワード)

String (文字列)

トラストストアを保護するために使用するパスワード。

Type (型)

String (文字列)

トラストストアの型。

Algorithm (アルゴリズム)

String (文字列)

トラストストアで使用する暗号化アルゴリズム。

Insecure (安全ではない)

Boolean (ブール)

true​ の場合、Mule では証明書の検証の実行を停止します。これを ​true​ に設定すると、接続が攻撃に対して脆弱になる可能性があります。

### [](#KeyStore)Keystore (キーストア) TLS プロトコル用のキーストアを設定します。生成したキーストアには、非公開キーと公開証明書が格納されます。
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

キーストアへのパス。Mule では、現在のクラスパスとファイルシステムへの相対的なパスを解決します。

Type (型)

String (文字列)

キーストアの種別。

Alias (別名)

String (文字列)

キーストアに複数の非公開キーが含まれている場合に使用するキーの別名。デフォルトでは、Mule はファイル内の最初のキーを使用します。

Key Password (キーパスワード)

String (文字列)

非公開キーを保護するために使用するパスワード。

Password (パスワード)

String (文字列)

キーストアを保護するために使用するパスワード。

Algorithm (アルゴリズム)

String (文字列)

キーストアで使用する暗号化アルゴリズム。

### [](#StandardRevocationCheck)Standard Revocation Check (標準の取り消し確認) TLS 証明書の標準取り消し確認を設定します。
項目 型 説明 デフォルト値 必須

Only End Entities (最後のエンティティのみ)

Boolean (ブール)

証明書チェーン内で確認する要素:

  • true​

    証明書チェーンの最後の要素のみを確認します。

  • false​

    証明書チェーンのすべての要素を確認します。

Prefer Crls (CRL を優先)

Boolean (ブール)

証明書の有効性を確認する方法:

  • true​

    証明書失効リスト (CRL) で証明書の有効性を確認します。

  • false​

    オンライン証明書状況プロトコル (OCSP) を使用して証明書の有効性を確認します。

No Fallback (代替なし)

Boolean (ブール)

証明書の有効性を確認するための第 2 の方法を使用するかどうか:

  • true​

    [Prefer Crls (CRL を優先)]​ 項目で指定されていない方法 (第 2 の方法) を使用して証明書の有効性を確認します。

  • false​

    証明書の有効性を確認するための第 2 の方法を使用しません。

Soft Fail (ソフトフェール)

Boolean (ブール)

取り消しサーバーに到達できない場合や取り消しサーバーが混雑している場合の処理:

  • true​

    検証エラーを回避します。

  • false​

    検証の失敗を許可します。

### [](#CustomOcspResponder)Custom OCSP Responder (カスタム OCSP レスポンダー) 証明書の取り消し確認のカスタム OCSP レスポンダーを設定します。
項目 型 説明 デフォルト値 必須

Url

String (文字列)

OCSP レスポンダーの URL。

Cert Alias (証明書の別名)

String (文字列)

OCSP 応答の署名証明書の別名。指定した場合、別名はトラストストアに存在する必要があります。

### [](#CrlFile)CRL File (CRL ファイル) 証明書失効リスト (CRL) ファイルの場所を指定します。
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

CRL ファイルへのパス。

### [](#reconnection-再接続)Reconnection (再接続) 操作の再接続戦略を設定します。
項目 型 説明 デフォルト値 必須

Fails Deployment (デプロイメントに失敗)

Boolean (ブール)

アプリケーションのデプロイ時に、関連する再接続戦略をすべて実行した後、接続テストに合格しない場合の処理:

  • true​

    デプロイメントの失敗を許可します。

  • false​

    接続テストの結果を無視します。

Reconnection Strategy (再接続戦略)

使用する再接続戦略。

### [](#reconnect-再接続)Reconnect (再接続) 標準再接続戦略を設定し、再接続の頻度と、コネクタソースまたは操作で実行できる再接続の試行回数を指定します。
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続を試行する頻度 (ミリ秒)。

Blocking

Boolean (ブール)

false​ の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

Count (数)

Number (数値)

Mule アプリケーションで実行できる再接続の試行回数。

### [](#reconnect-forever-繰り返し再接続)Reconnect Forever (繰り返し再接続) Mule アプリケーションが実行されている間はコネクタソースや操作によって指定された頻度で再接続が試行される Forever 再接続戦略を設定します。
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続を試行する頻度 (ミリ秒)。

Blocking

Boolean (ブール)

false​ の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

### [](#ExpirationPolicy)Expiration Policy (有効期限ポリシー) 有効期限ポリシー戦略を設定します。
項目 型 説明 デフォルト値 必須

Max Idle Time (最大アイドル時間)

Number (数値)

動的設定インスタンスがアイドル状態を続けられる最大時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。

Time Unit (時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Max Idle Time (最大アイドル時間)]​ 項目の時間単位。

### [](#HttpResponseAttributes)HTTP Response Attributes (HTTP 応答属性) 設定の HTTP 応答属性を設定します。
項目 型 説明 デフォルト値 必須

Status Code (状況コード)

Number (数値)

応答の HTTP 状況コード。

x

Headers (ヘッダー)

Object (オブジェクト)

メッセージ内の HTTP ヘッダーのマッピング。

x

Reason Phrase (理由を示す語句)

String (文字列)

応答の HTTP の理由を示す語句。

x

### [](#RedeliveryPolicy)Redelivery Policy (再配信ポリシー) エラーを生成する要求を実行するための再配信ポリシーを設定します。再配信ポリシーは、フロー内のあらゆる提供元に追加できます。
項目 型 説明 デフォルト値 必須

Max Redelivery Count (最大再配信数)

Number (数値)

再配信される要求の最大処理失敗回数。この回数を超えると、​REDELIVERY_EXHAUSTED​ エラーが返されます。

Message Digest Algorithm (メッセージダイジェストアルゴリズム)

String (文字列)

[Use Secure Hash (セキュアハッシュを使用)]​ 項目が ​true​ の場合に使用するセキュアハッシュアルゴリズム。メッセージのペイロードが Java オブジェクトの場合、Mule ではこの値が無視され、ペイロードの ​hashCode()​ が返した値が返されます。

Message Identifier (メッセージ識別子)

メッセージが再配信されたかどうかを判断する 1 つ以上の式。このプロパティは、​[Use Secure Hash (セキュアハッシュを使用)]​ 項目が ​false​ の場合にのみ設定できます。

Object Store (オブジェクトストア)

ObjectStore

各メッセージの再配信カウンターが保存されるオブジェクトストアを設定します。

### [](#RedeliveryPolicyMessageIdentifier)Redelivery Policy Message Identifier (再配信ポリシーメッセージ識別子) 再配信されたメッセージを識別する方法と、メッセージがいつ再配信されたのかを見つける方法を設定します。
項目 型 説明 デフォルト値 必須

Use Secure Hash (セキュアハッシュを使用)

Boolean (ブール)

true​ の場合、Mule では再配信されたメッセージの識別にセキュアハッシュアルゴリズムを使用します。

Id Expression (ID 式)

String (文字列)

メッセージがいつ再配信されたのかを判断する 1 つ以上の式。このプロパティは、​[Use Secure Hash (セキュアハッシュを使用)]​ 項目が ​false​ の場合にのみ設定できます。

### [](#RepeatableInMemoryStream)Repeatable In Memory Stream (反復可能なメモリ内ストリーム) データが最大バッファサイズを超えた場合に要求が失敗するメモリ内ストリーミング戦略を設定します。ユースケースで最適なバッファサイズは、必ずパフォーマンステストを実施して決めてください。
項目 型 説明 デフォルト値 必須

Initial Buffer Size (初期バッファサイズ)

Number (数値)

データストリームに割り当てるメモリの初期容量。ストリーミングされたデータがこの値を超える場合は、​[Buffer Size Increment (バッファサイズ増分)]​ の単位で ​[Max In Memory Size (最大メモリ内サイズ)]​ 値を上限としてバッファが拡張されます。

Buffer Size Increment (バッファサイズ増分)

Number (数値)

バッファサイズが初期サイズを超えた場合に、拡張する量。値を ​0​ またはそれ以下に設定すると、バッファは拡張されません。

Max Buffer Size (最大バッファサイズ)

Number (数値)

使用するメモリの最大量。これを超えると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。0 以下の値は無制限を意味します。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Initial Buffer Size (初期バッファサイズ)]​ 項目、​[Buffer Size Increment (バッファサイズ増分)]​ 項目、​[Buffer Unit (バッファ単位)]​ 項目の単位。

### [](#RepeatableFileStoreStream)Repeatable File Store Stream (反復可能なファイルストアストリーム) 反復可能なファイルストアストリーミング戦略を設定します。この戦略では、ストリームコンテンツの一部がメモリ内に格納されます。ストリームのコンテンツが、設定されたバッファサイズよりも大きい場合、Mule はバッファのコンテンツをディスクにバックアップしてからメモリをクリアします。
項目 型 説明 デフォルト値 必須

In Memory Size (メモリ内サイズ)

Number (数値)

ストリームのデータで使用できるメモリの最大量。メモリ量がこの値を超えると、コンテンツはディスクにバッファされます。パフォーマンスを最適化する方法は、次のとおりです。

  • バッファサイズを大きくすると、Mule がバッファをディスクに書き込む回数を減らせます。これによってパフォーマンスが高まりますが、より多くのメモリが必要になるため、アプリケーションが処理できる同時要求数が制限されます。

  • バッファサイズを小さくすると、メモリの負荷は低減しますが、応答時間が長くなります。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[In Memory Size (メモリ内サイズ)]​ 項目の単位。

### [](#RepeatableInMemoryIterable)Repeatable In Memory Iterable (反復可能なメモリ内イテラブル)
項目 型 説明 デフォルト値 必須

Initial Buffer Size (初期バッファサイズ)

Number (数値)

ストリームをコンシュームし、ランダムアクセスを提供するために、最初にメモリ内に保持するインスタンスの量。ストリームのデータ量がこのバッファサイズを超える場合は、​[Buffer Size Increment (バッファサイズ増分)]​ 属性に従って、​[Max In Memory Size (最大メモリ内サイズ)]​ を上限としてバッファが拡張されます。デフォルト値は 100 インスタンスです。

Buffer Size Increment (バッファサイズ増分)

Number (数値)

バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を ​0​ 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。デフォルト値は 100 インスタンスです。

Max Buffer Size (最大バッファサイズ)

Number (数値)

使用するメモリの最大量。これを超えると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。​0​ 以下の値は無制限を意味します。

### [](#RepeatableFileStoreIterable)Repeatable File Store Iterable (反復可能なファイルストアイテラブル)
項目 型 説明 デフォルト値 必須

In Memory Objects (メモリ内オブジェクト)

Number (数値)

メモリ内に保持されるインスタンスの最大数。これ以上の量が必要な場合、ディスク上のコンテンツがバッファされます。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[In Memory Size (メモリ内サイズ)]​ 項目の単位。

## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Google BigQuery Connector 1.1 Google BigQuery 用 Anypoint Connector (Google BigQuery Connector) では、Google BigQuery とオンプレミスまたはクラウドのサードパーティアプリケーション間でデータを同期し、ビジネスプロセスを自動化します。 互換性と修正された問題については、「Google BigQuery Connector リリースノート」を参照してください。 ## [](#始める前に)始める前に このコネクタを使用するには、以下に精通している必要があります。 - Google BigQuery API - Anypoint Connector - Mule Runtime Engine (Mule) - Mule フローの要素とグローバル要素 - Anypoint Studio を使用した Mule アプリケーションの作成方法 アプリケーションを作成する前に、以下が必要です。 - Google BigQuery の対象リソースにアクセスするためのログイン情報 - Anypoint Platform - Anypoint Studio バージョン 7.3.5 以降 ## [](#コネクタの一般的なユースケース)コネクタの一般的なユースケース 次に、Google BigQuery Connector の一般的なユースケースを示します。 - ログとイベントデータコレクションを使用して問題を分析する - Google BigQuery のデータを挿入、更新、削除する - Google BigQuery でクエリを実行する これらのユースケースの例については、​[「Google BigQuery Connector の例」](https://docs.mulesoft.com/jp/google-bigquery-connector/1.1/google-bigquery-connector-examples)​を参照してください。 ## [](#接続種別)接続種別 Google BigQuery 接続では、次の認証種別を使用します。 - JWT 接続 認証でトークンを使用します。 - OAuth2 接続 サービスアカウント認証を使用します。 認証種別の設定についての詳細は、​[「コネクタのグローバル要素の設定」](https://docs.mulesoft.com/jp/google-bigquery-connector/1.1/google-bigquery-connector-studio#configure-global-element)​を参照してください。 ## [](#次のステップ)次のステップ 前提条件を満たしたら、​[Anypoint Studio](https://docs.mulesoft.com/jp/google-bigquery-connector/1.1/google-bigquery-connector-studio)​ でアプリケーションを作成してコネクタを設定できます。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [Exchange を使用したコネクタ、テンプレート、およびサンプルの検出](https://docs.mulesoft.com/connectors/introduction/intro-use-exchange) - [Google BigQuery Connector リファレンス](https://docs.mulesoft.com/jp/google-bigquery-connector/1.1/google-bigquery-connector-reference) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Google BigQuery Connector 1.1 - XML と Maven のサポート XML で Mule アプリケーションを手動でコーディングすることもできますが、Anypoint Studio を使用した方が効率的です。 - Mule Runtime Engine (Mule) アプリケーションを (Anypoint Studio の XML エディターまたはテキストエディターから) 手動でコーディングする場合、参照ステートメントを XML Mule フローと Apache Maven ​`pom.xml`​ ファイルの両方に追加することで、アプリケーションからコネクタにアクセスできます。 - Studio でコネクタを追加すると、Studio は自動的に XML コードにコネクタの名前空間およびスキーマの場所を入力し、​`pom.xml`​ ファイルに連動関係を追加します。 ## [](#コネクタの名前空間の追加)コネクタの名前空間の追加 次のコードを設定 XML のヘッダーの ​`mule`​ タグ内に貼り付けます。 ```xml http://www.mulesoft.org/schema/mule/google-bigquery http://www.mulesoft.org/schema/mule/google-bigquery/current/mule-google-bigquery.xsd ``` 次の例は、XML 内に名前空間ステートメントが配置される方法を示しています。 ```xml ``` ## [](#pom-ファイルの連動関係の追加)POM ファイルの連動関係の追加 Apache Maven ​`pom.xml`​ ファイルは Anypoint Studio によって生成され、Mule アプリケーションの連動関係が含まれます。Mule アプリケーションを手動でコーディングする場合、次の XML スニペットを ​`pom.xml`​ ファイルに含めてこのコネクタにアクセスできるようにします。 ```xml com.mulesoft.connectors mule4-google-bigquery x.x.x mule-plugin ``` ``​ を使用しているコネクタに対応するバージョンに置き換えます。 最新の ​`pom.xml`​ ファイル情報を取得する手順は、次のとおりです。 1. [Anypoint Exchange](https://www.mulesoft.com/exchange/)​ に移動します。 2. Exchange で、​**\[Login (ログイン)\]**​ をクリックし、Anypoint Platform のユーザー名とパスワードを指定します。 3. Exchange で、「​`google bigquery`​」を検索します。 4. コネクタを選択します。 5. 画面の右上付近にある ​**\[Dependency Snippets (連動関係スニペット)\]**​ をクリックします。 ## [](#次のステップ)次のステップ 名前空間および ​`pom.xml`​ ファイルを完了したら、​[例](https://docs.mulesoft.com/jp/google-bigquery-connector/1.1/google-bigquery-connector-examples)​を試すことができます。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Google BigQuery Connector 1.1 の例 Google BigQuery Connector の Mule フローの例を次にいくつか示します。 - [ジョブの取得](#get-job) - [ジョブの挿入](#insert-job) - [ジョブの削除](#delete-job) - [クエリ結果の取得](#get-query-result) - [ジョブのキャンセル](#cancel-job) - [ジョブのリスト](#list-jobs) - [クエリ](#query) - [On Table Row の使用](#on-table-row) - [認証](#authorize) - [HTML フォームの表示](#html-form) ## [](#始める前に)始める前に - Java 8 または 11 - Anypoint Studio 7.5 以降 - Mule Runtime Engine (Mule) 4.3.0 以降 - DataWeave - Google API の OAuth ログイン情報 ## [](#接続の設定)接続の設定 接続を保護するには、OAuth 接続項目の値を指定する必要があります。次の手順を実行します。 - [接続の設定ファイルを作成する](#create-config-file)​。 - [接続のグローバル要素を設定する](#configure-conn)​。 - [プロパティファイルのグローバル要素を設定する](#configure-global)​。 ### [](#create-config-file)接続の設定ファイルを作成する 接続のプロパティが含まれる設定ファイルを作成します。 1. `/src/main/resources/`​ フォルダー内に ​`mule-app.properties`​ という名前のファイルを作成します。 2. `mule-app.properties`​ ファイルに、次のような接続の一連のプロパティを作成します。括弧で囲まれたテキスト (括弧を含む) を各自の設定の適切な値に置き換えます。 config.consumerKey= config.consumerSecret= これは、選択した接続設定によって異なる場合があります。 プロパティファイルの作成についての詳細は、​[「プロパティプレースホルダーの設定」](https://docs.mulesoft.com/mule-runtime/latest/mule-app-properties-to-configure)​を参照してください。 ### [](#configure-conn)接続のグローバル要素を設定する 接続のグローバル要素を設定します。 1. 新しい Mule プロジェクトを作成します。 2. **\[Mule Palette (Mule パレット)\]**​ ビューで、​**\[Search in Exchange (Exchange 内を検索)\]**​ をクリックして「​`google bigquery`​」と入力します。 3. **\[Google BigQuery Connector\]**​ を ​**\[Selected modules (選択済みモジュール)\]**​ セクションに追加し、​**\[Finish (完了)\]**​ をクリックします。 4. **\[Global Elements (グローバル要素)\]**​ タブをクリックし、​**\[Create (作成)\]**​ をクリックします。 5. **\[Connector Configuration (コネクタ設定)\] > \[Google BigQuery Config (Google BigQuery 設定)\]**​ を選択し、​**\[OK\]**​ をクリックします。 6. JWT または OAuth2 を設定するための値を入力します。コネクタ設定の項目に入力する値についての詳細は、​[「コネクタのグローバル要素を設定する」](https://docs.mulesoft.com/jp/google-bigquery-connector/1.1/google-bigquery-connector-studio#configure-global-element)​を参照してください。 7. **\[Test Connection (接続をテスト**​)\] ボタンをクリックして、Google API と接続されていることを確認します。ポップアップに成功メッセージが表示されます。 8. **\[OK\]**​ をクリックします。 9. **\[Global Element Configuration (グローバル要素設定)\]**​ で HTTPS リスナー設定を開きます。 10. **\[TLS\]**​ タブをクリックし、\[TLS Configuration (TLS 設定)\] > \[Edit inline (インライン編集)\] を選択します。 11. 生成されたキーストアの詳細を使用して ​**\[Key Store Configuration (キーストア設定)\]**​ を指定し、この設定で HTTPS を有効にします。 12. **\[OK\]**​ をクリックします。 ### [](#configure-global)プロパティファイルのグローバル要素を設定する `mule-app.properties`​ ファイルのグローバル要素を設定して、Mule がその場所を認識できるようにします。 1. **\[Global Elements (グローバル要素)\]**​ タブをクリックし、​**\[Create (作成)\]**​ をクリックします。 2. **\[Choose Global Type (グローバル種別の選択)\]**​ ダイアログで、​**\[Configuration properties (設定プロパティ)\]**​ を選択し、​**\[OK\]**​ をクリックします。 3. **\[File (ファイル)\]**​ 項目に「​`mule.app.properties`​」と入力します。 4. **\[OK\]**​ をクリックします。 ## [](#get-job)ジョブの取得 この Mule フローでは、指定されたジョブ ID からジョブを取得します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Get Job**​ ジョブを取得します。 次の値を入力します。
項目 値

Job id (ジョブ ID)

attributes.queryParams.jobId

- **Logger**​ **Get Job**​ 操作からの HTTP 応答を表示します。 ![Get Job 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/get-job.png) ### [](#この例の-xml)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#insert-job)ジョブの挿入 この Mule フローでは、入力設定を使用してジョブを挿入します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Insert Job**​ ジョブを挿入します。 次の値を入力します。
項目 値

Job values content (ジョブ値のコンテンツ)

payload

- **Logger**​ **Insert Job**​ 操作からの HTTP 応答を表示します。 ![Insert Job 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/insert-job.png) ### [](#この例の-xml-2)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-2)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#delete-job)ジョブの削除 この Mule フローでは、指定されたジョブ ID からジョブを削除します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Delete Job**​ ジョブを削除します。 次の値を入力します。
項目 値

Job id (ジョブ ID)

attributes.queryParams.jobId

- **Logger**​ **Delete Job**​ 操作からの HTTP 応答を表示します。 ![Delete Job 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/delete-job.png) ### [](#この例の-xml-3)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-3)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#get-query-result)クエリ結果の取得 この Mule フローでは、クエリの結果を取得します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Get Query Results**​ クエリの結果を取得します。 次の値を入力します。
項目 値

Job id (ジョブ ID)

attributes.queryParams.jobId

Start Index (開始インデックス)

0

Max Results (最大結果数)

25

- **Logger**​ **Get Query Result**​ 操作からの HTTP 応答を表示します。 ![Get Query Result 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/get-query-result.png) ### [](#この例の-xml-4)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-4)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#cancel-job)ジョブのキャンセル この Mule フローでは、指定されたジョブ ID からジョブをキャンセルします。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Cancel Job**​ ジョブをキャンセルします。 次の値を入力します。
項目 値

Job id (ジョブ ID)

attributes.queryParams.jobId

Content-Type (コンテンツタイプ)

application/json

- **Logger**​ **Cancel Job**​ 操作からの HTTP 応答を表示します。 ![Cancel Job 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/cancel-job.png) ### [](#この例の-xml-5)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-5)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#list-jobs)ジョブのリスト この Mule フローでは、プロジェクトからジョブを取得します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **List Jobs**​ ジョブをリストします。 次の値を入力します。
項目 値

Content-Type (コンテンツタイプ)

application/json

Max Results (最大結果数)

30

Pretty Print (プリティプリント)

False (デフォルト)

- **Logger**​ **List Jobs**​ 操作からの HTTP 応答を表示します。 ![List Jobs 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/list-jobs.png) ### [](#この例の-xml-6)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-6)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#query)クエリ この Mule フローでは、クエリジョブ値で指定されたクエリを実行します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Query**​ クエリを実行します。 次の値を入力します。
項目 値

Query values content (クエリ値のコンテンツ)

%dw 2.0
output application/json
---

payload
- **For Each**​ 複数のコンポーネントを反復処理します。 次の値を入力します。
項目 値

Counter Variable Name (カウンター変数名)

counter

Batch Size (バッチサイズ)

1

Root Message Variable Name (ルートメッセージ変数名)

rootMessage

- **Transform Message**​ **Query**​ 操作の結果を JSON 形式で出力します。 %dw 2.0 output application/json var resultt = read(payload."output","application/json") --- ((resultt.f) map ((item, index) -> {(payload.attributes.tableSchema.fields\[index\].name as String) : item.v} )) reduce ((item, accumulator) -> accumulator ++ item) - **Logger**​ **Query**​ 操作からの HTTP 応答を表示します。 ![Query 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/query.png) ### [](#この例の-xml-7)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml {(payload.attributes.tableSchema.fields[index].name as String) : item.v} )) reduce ((item, accumulator) -> accumulator ++ item) ]]> ``` ### [](#この例の実行手順-7)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#on-table-row)On Table Row の使用 この Mule フローでは、​**On Table Row**​ ソースを使用します。 この例では、次の操作を使用します。 - **On Table Row**​ ウォーターマークに基づいてテーブルのすべての行を返します。 次の値を入力します。
項目 値

Scheduling Strategy (スケジュール戦略)

Fixed Frequency

Frequency (頻度)

1000

Start delay (開始遅延)

0

Time unit (時間単位)

MILLISECONDS (Default)

Dataset name (データセット名)

test124

Table name (テーブル名)

table_data

Watermark column (ウォーターマーク列)

id

Since (以降)

1

Column id (列 ID)

id

- **Logger**​ **On Table Row**​ ソースからの HTTP 応答を表示します。 - **Transform Message**​ **On Table Row**​ 操作の結果を JSON 形式で出力します。 %dw 2.0 output application/json --- payload ![On Table Row ソースの Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/on-table-row.png) ### [](#この例の-xml-8)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-8)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#authorize)認証 この Mule フローでは、接続を認証します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Request**​ HTTP サービスをコンシュームします。 次の値を入力します。
項目 値

Method (メソッド)

GET (Default)

Path (パス)

/authorize?resourceOwnerId=demo

Body (本文)

payload

- **Logger**​ **Request**​ 操作からの HTTP 応答を表示します。 ![Request 操作の Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/authorize.png) ### [](#この例の-xml-9)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-9)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#html-form)HTML フォームの表示 この Mule フローでは、HTML フォームを表示します。 この例では、次の操作を使用します。 - **HTTP Listener**​ HTTP 要求からデータを受け取ります。 - **Parse Template**​ テンプレートを処理します。 次の値を入力します。
項目 値

Location (場所)

index.html

![Parse Template コンポーネントの Studio フロー](/mulesoft/current/ja-jp/google-bigquery-connector/1.1/_images/html-form.png) ### [](#この例の-xml-10)この例の XML この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。 ```xml ``` ### [](#この例の実行手順-10)この例の実行手順 1. コネクタが設定されていることを確認します。 2. プロジェクトを保存します。 3. OAuth2 認証の ​**\[Authorize (認証)\]**​ ボタンをクリックします。 4. Web ブラウザーから「​`http://{app-name}.cloudhub.io`​」と入力してアプリケーションをテストします。 ## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com) # Google BigQuery Connector 1.1 リファレンス ## [](#設定)設定 * * * ### [](#Config)Configuration (設定) #### [](#パラメーター)パラメーター
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

Connection (接続)

この設定の接続種別。

x

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

30

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

SECONDS

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

AUTO

Name (名前)

String (文字列)

この設定の参照に使用される ID。

x

Expiration Policy (有効期限ポリシー)

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。

#### [](#接続種別)接続種別 ##### [](#Config_Jwt)JWT 接続 ###### [](#パラメーター-2)パラメーター
名前 型 説明 デフォルト値 必須

Project Id (プロジェクト ID)

String (文字列)

プロジェクト ID。

Base Uri (ベース URI)

String (文字列)

パラメーターのベース URI。各インスタンスまたはテナントが独自のベース URI を取得します。

https://bigquery.googleapis.com/bigquery/v2

Default Headers (デフォルトヘッダー)

Object (オブジェクト)

要求に含めるデフォルトヘッダー。

Query Parameters (クエリパラメーター)

Object (オブジェクト)

要求に含めるクエリパラメーター。

Connection Timeout (接続タイムアウト)

Number (数値)

リモートサーバーへの接続を確立するときのコネクタの待機時間。この時間を経過するとタイムアウトします。

30

Connection Timeout Unit (接続タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Connection Timeout (接続タイムアウト)]​ 項目の時間単位。

SECONDS

Use Persistent Connections (永続接続を使用)

Boolean (ブール)

永続接続を使用するかどうかを示します。

  • true​

    Mule は永続接続を使用します。

  • false​

    Mule は最初の要求が完了すると接続を閉じます。

true

Max Connections (最大接続数)

Number (数値)

バックエンドに対して開く接続の最大数。HTTP 要求は、複数の接続を介して並行して送信されます。この値の設定が高すぎると、レイテンシーに影響し、スループットを高めることなく追加リソースがコンシュームされる可能性があります。

-1

Connection Idle Timeout (接続アイドルタイムアウト)

Number (数値)

永続接続が有効になっている場合、接続が Mule によって閉じられるまでアイドル状態を維持できる時間。

30

Connection Idle Timeout Unit (接続アイドルタイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Connection Idle Timeout (接続アイドルタイムアウト)]​ 項目の時間単位。

SECONDS

Proxy Config (プロキシ設定)

アウトバウンド接続のプロキシを設定します。

Stream Response (応答のストリーミング)

Boolean (ブール)

この値が ​true​ の場合、Mule は受信した応答をストリーミングします。

false

Response Buffer Size (応答バッファサイズ)

Number (数値)

HTTP 応答が保存されるバッファのサイズ (バイト)。

-1

Name app (アプリケーションの名前付け)

String (文字列)

パラメーターアプリケーション名。

appName1

Private Key Id (非公開キー ID)

String (文字列)

Google 接続アプリケーションの非公開キー ID。

x

Private Key (非公開キー)

String (文字列)

Google 接続アプリケーションの非公開キー。

x

Issuer (発行者)

String (文字列)

クライアントメール。

x

Audience Url (オーディエンス URL)

String (文字列)

オーディエンスは対象オーディエンスとして認証サーバーを識別します。認証サーバーは、トークンの対象オーディエンスであることを確認する必要があります。オーディエンス値に認証サーバーの URL を使用します: https://bigquery.googleapis.com/​。

https://bigquery.googleapis.com/

Token Timeout (トークンタイムアウト)

Number (数値)

トークンのタイムアウト。

3600

Token Timeout Unit (トークンタイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Token Timeout (トークンタイムアウト)]​ 項目の時間単位。

SECONDS

Protocol (プロトコル)

Enumeration (列挙)。次のいずれかになります。 HTTP HTTPS

通信に使用するプロトコル。

HTTP

TLS Configuration (TLS 設定)

TLS

TLS 設定。

Reconnection (再接続)

アプリケーションのデプロイ時に、関連する再接続戦略をすべて実行した後、接続テストに合格しない場合の処理:

  • true​

    デプロイメントの失敗を許可します。

  • false​

    接続テストの結果を無視します。

##### [](#Config_Oauth2)OAuth2 接続 Unresolved include directive in modules/ROOT/pages/google-bigquery-connector-reference.adoc - include::connectors::partial$oauth2-description.adoc\[\] ###### [](#パラメーター-3)パラメーター
名前 型 説明 デフォルト値 必須

Project Id (プロジェクト ID)

String (文字列)

プロジェクト ID。

Base Uri (ベース URI)

String (文字列)

パラメーターのベース URI。各インスタンスまたはテナントが独自のパラメーターベース URI を取得します。

https://bigquery.googleapis.com/bigquery/v2

Default Headers (デフォルトヘッダー)

Object (オブジェクト)

要求に含めるデフォルトヘッダー。

Query Parameters (クエリパラメーター)

Object (オブジェクト)

要求に含めるクエリパラメーター。

Connection Timeout (接続タイムアウト)

Number (数値)

リモートサーバーへの接続を確立するときのコネクタの待機時間。この時間を経過するとタイムアウトします。

30

Connection Timeout Unit (接続タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Connection Timeout (接続タイムアウト)]​ 項目の時間単位。

SECONDS

Use Persistent Connections (永続接続を使用)

Boolean (ブール)

永続接続を使用するかどうかを示します。

  • true​

    Mule は永続接続を使用します。

  • false​

    Mule は最初の要求が完了すると接続を閉じます。

true

Max Connections (最大接続数)

Number (数値)

バックエンドに対して開く接続の最大数。HTTP 要求は、複数の接続を介して並行して送信されます。この値の設定が高すぎると、レイテンシーに影響し、スループットを高めることなく追加リソースがコンシュームされる可能性があります。

-1

Connection Idle Timeout (接続アイドルタイムアウト)

Number (数値)

永続接続が有効になっている場合、接続が Mule によって閉じられるまでアイドル状態を維持できる時間。

30

Connection Idle Timeout Unit (接続アイドルタイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Connection Idle Timeout (接続アイドルタイムアウト)]​ 項目の時間単位。

SECONDS

Proxy Config (プロキシ設定)

アウトバウンド接続のプロキシを設定します。

Stream Response (応答のストリーミング)

Boolean (ブール)

この値が ​true​ の場合、Mule は受信した応答をストリーミングします。

false

Response Buffer Size (応答バッファサイズ)

Number (数値)

HTTP 応答が保存されるバッファのサイズ (バイト)。

-1

Name app (アプリケーションの名前付け)

String (文字列)

パラメーターアプリケーション名。

appName1

Access_type

String (文字列)

ユーザーがブラウザーにいない場合にアクセストークンを更新するかどうかを示します。

  • online (オンライン)

    アクセストークンを取得します。

  • offline (オフライン)

    更新トークンとアクセストークンを取得します。

offline (オフライン)

Prompt (プロンプト)

String (文字列)

要求メッセージ。

consent (同意)

Refresh Token Condition (更新トークン条件)

String (文字列)

更新条件。

Protocol (プロトコル)

Enumeration (列挙)。次のいずれかになります。

  • HTTP

  • HTTPS

通信に使用するプロトコル。

HTTP

TLS Configuration (TLS 設定)

TLS

TLS を設定します。HTTPS プロトコルを使用する場合、TLS を設定する必要があります。

Reconnection (再接続)

アプリケーションのデプロイ時に、関連する再接続戦略をすべて実行した後、接続テストに合格しない場合の処理:

  • true​

    デプロイメントの失敗を許可します。

  • false​

    接続テストの結果を無視します。

Consumer Key (コンシューマーキー)

String (文字列)

サービスプロバイダーに登録されている OAuth コンシューマーキー。

x

Consumer Secret (コンシューマーシークレット)

String (文字列)

サービスプロバイダーに登録されている OAuth コンシューマーシークレット。

x

Authorization Url (認証 URL)

String (文字列)

サービスプロバイダーの認証エンドポイントの URL。

https://accounts.google.com/o/oauth2/auth

Access Token Url (アクセストークン URL)

String (文字列)

サービスプロバイダーのアクセストークンエンドポイントの URL。

https://oauth2.googleapis.com/token

Scopes (スコープ)

String (文字列)

OAuth ダンス時に要求する OAuth スコープ。この値のデフォルトはアノテーションのスコープです。

https://www.googleapis.com/auth/bigquery

Resource Owner Id (リソースオーナー ID)

String (文字列)

認証コード許可種別で使用するリソースオーナー ID。

Before (前)

String (文字列)

OAuth ダンスを開始する直前に実行するフローの名前。

After (後)

String (文字列)

アクセストークンを受信した直後に実行するフローの名前。

Listener Config (リスナー設定)

String (文字列)

アクセストークンコールバックエンドポイントで要求をリスンする HTTP リスナー設定。

x

Callback Path (コールバックパス)

String (文字列)

アクセストークンコールバックエンドポイントのパス。

x

Authorize Path (認証パス)

String (文字列)

OAuth ダンスをトリガーするローカル HTTP エンドポイントのパス。

x

External Callback Url (外部コールバック URL)

String (文字列)

コールバックエンドポイントがプロキシの背後にあるか、間接 URL でアクセスする場合にコールバックエンドポイントにアクセスするために OAuth プロバイダーで使用する URL。

Object Store (オブジェクトストア)

String (文字列)

各リソースオーナーのデータを保存するオブジェクトストアを設定します。設定されていない場合、Mule ではデフォルトのオブジェクトストアが使用されます。

## [](#サポートされている操作)サポートされている操作 - [Cancel Job](#CancelJob) - [Delete Job](#DeleteJob) - [Get Job](#GetJob) - [Get Query Results](#GetQueryResults) - [Insert Job](#InsertJob) - [List Jobs](#ListJobs) - [Query](#Query) - [Unauthorize](#Unauthorize) ## [](#関連付けられたソース)関連付けられたソース - [On Table Row](#OnTableRow) ## [](#操作)操作 ### [](#CancelJob)Cancel Job `` ジョブをキャンセルします。この操作では、/project/{projectId}/jobs/{jobId}/cancel エンドポイントに対する HTTP POST 要求を行います。 #### [](#パラメーター-4)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job id (ジョブ ID)

String (文字列)

ジョブ ID。

x

Content Type (コンテンツタイプ)

String (文字列)

コンテンツタイプ。

application/json

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力)出力

型

Any (任意)

Attributes Type (属性型)

#### [](#次の設定の場合)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:RETRY\_EXHAUSTED - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#DeleteJob)Delete Job `` ジョブを削除します。この操作では、/project/{projectId}/job/{jobId} エンドポイントに対する HTTP DELETE 要求を行います。 #### [](#パラメーター-5)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job id (ジョブ ID)

String (文字列)

ジョブ ID。

x

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#次の設定の場合-2)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-2)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:RETRY\_EXHAUSTED - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#GetJob)Get Job `` ジョブを取得します。この操作では、/project/{projectId}/jobs/{jobId} エンドポイントに対する HTTP GET 要求を行います。 #### [](#パラメーター-6)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job id (ジョブ ID)

String (文字列)

ジョブ ID。

x

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-2)出力

型

Any (任意)

Attributes Type (属性型)

#### [](#次の設定の場合-3)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-3)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:RETRY\_EXHAUSTED - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#GetQueryResults)Get Query Results `` クエリの結果を取得します。この操作では、/projects/{projectId}/queries/{jobId} エンドポイントに対する HTTP GET 要求を行います。 #### [](#パラメーター-7)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job id (ジョブ ID)

String (文字列)

ジョブ ID。

Start Index (開始インデックス)

Number (数値)

開始行の開始値 0 のインデックス。

0

Max Results (最大結果数)

Number (数値)

ページごとに返されるコメントの最大数。

30

Page Token (ページトークン)

String (文字列)

次のページで前のリスト要求を続行するためのトークン。このパラメーターは前の応答からの ​nextPageToken​ の値に設定します。この項目は ​[Start Index (開始インデックス)]​ と ​[Max Results (最大結果数)]​ よりも優先されます。

Location (場所)

String (文字列)

ジョブの地理的場所。

Time out (タイムアウト)

String (文字列)

クエリの完了を待機する最大時間 (ミリ秒) を指定します。

Output Mime Type (出力 MIME タイプ)

String (文字列)

この操作で出力されるペイロードの MIME タイプ。

Output Encoding (出力エンコード)

String (文字列)

この操作で出力されるペイロードのエンコード。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-3)出力

型

Any の配列

Attributes Type (属性型)

Any の配列

#### [](#次の設定の場合-4)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-4)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#InsertJob)Insert Job `` ジョブを挿入します。この操作では、/project/{projectId}/jobs エンドポイントに対する HTTP POST 要求を行います。 #### [](#パラメーター-8)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Job Values Content (ジョブ値のコンテンツ)

Any (任意)

ジョブ値のコンテンツ。

x

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-4)出力

型

Any (任意)

Attributes Type (属性型)

#### [](#次の設定の場合-5)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-5)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:RETRY\_EXHAUSTED - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#ListJobs)List Jobs `` ジョブをリストします。この操作では、/projects/{projectId}/jobs エンドポイントに対する HTTP GET 要求を行います。 #### [](#パラメーター-9)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Content Type (コンテンツタイプ)

String (文字列)

コンテンツタイプ。

application/json

Max Results (最大結果数)

Number (数値)

ページごとに返されるコメントの最大数。

30

Pretty Print (プリティプリント)

Boolean (ブール)

インデントと改行を含む応答を返します。

false

Page Token (ページトークン)

String (文字列)

次のページで前のリスト要求を続行するためのトークン。このパラメーターは前の応答からの ​nextPageToken​ の値に設定します。

Quota User (クォータユーザー)

String (文字列)

クォータの目的のユーザーを表す不透明な文字列。40 文字までです。

User Ip (ユーザー IP)

String (文字列)

非推奨になりました。代わりに ​[Quota User (クォータユーザー)]​ を使用します。

fields (項目)

String (文字列)

部分的な応答に含める項目を指定するセレクター。

Min Created Time (最小作成時刻)

String (文字列)

結果コメントの ​modifiedTime​ の最小値 (RFC 3339 日時)。

Max Created Time (最大作成時刻)

String (文字列)

結果コメントの ​modifiedTime​ の最大値 (RFC 3339 日時)。

Output Mime Type (出力 MIME タイプ)

String (文字列)

この操作で出力されるペイロードの MIME タイプ。

Output Encoding (出力エンコード)

String (文字列)

この操作で出力されるペイロードのエンコード。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-5)出力

型

Any の配列

#### [](#次の設定の場合-6)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-6)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#Query)Query `` クエリを実行します。この操作では、/projects/{projectId}/queries エンドポイントに対する HTTP POST クエリ要求を行います。 #### [](#パラメーター-10)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Query Values Content (クエリ値のコンテンツ)

Any (任意)

クエリ値のコンテンツ。

x

Output Mime Type (出力 MIME タイプ)

String (文字列)

この操作で出力されるペイロードの MIME タイプ。

Output Encoding (出力エンコード)

String (文字列)

この操作で出力されるペイロードのエンコード。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Custom Query Parameters (カスタムクエリパラメーター)

Object (オブジェクト)

要求に含めるカスタムクエリパラメーター。指定したクエリパラメーターは設定で指定したデフォルトクエリパラメーターとマージされます。

Custom headers (カスタムヘッダー)

Object (オブジェクト)

要求に含めるカスタムヘッダー。指定したカスタムヘッダーは設定で指定したデフォルトヘッダーとマージされます。

Response Timeout (応答タイムアウト)

Number (数値)

Mule が応答の完了を待機する時間。この時間が経過すると、要求がタイムアウトします。

Response Timeout Unit (応答タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Response Timeout (応答タイムアウト)]​ 項目の時間単位。

Streaming Type (ストリーミング種別)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • ALWAYS

  • NEVER

コネクタが要求のコンテンツをリモートサービスにストリーミングする方法。

  • AUTO​ (デフォルト)

    コネクタは、要求コンテンツに基づいて自動的に最適なストリーミング戦略を使用します。

  • ALWAYS​

    コネクタは、常に要求コンテンツをストリーミングします。

  • NEVER​

    コネクタは、要求コンテンツをストリーミングしません。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-6)出力

型

Any の配列

Attributes Type (属性型)

Any の配列

#### [](#次の設定の場合-7)次の設定の場合 - [Configuration (設定)](#Config) #### [](#スロー-7)スロー - BIGQUERY:BAD\_REQUEST - BIGQUERY:CLIENT\_ERROR - BIGQUERY:CONNECTIVITY - BIGQUERY:INTERNAL\_SERVER\_ERROR - BIGQUERY:NOT\_FOUND - BIGQUERY:PROJECT\_NOT\_FOUND - BIGQUERY:SERVER\_ERROR - BIGQUERY:TIMEOUT - BIGQUERY:UNAUTHORIZED ### [](#Unauthorize)Unauthorize `` 特定のリソースオーナー ID のアクセストークン情報をすべて削除して、認証ダンスを再度実行しない限り、そのユーザー向けの操作を実行できないようにします。 #### [](#パラメーター-11)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Resource Owner Id (リソースオーナー ID)

String (文字列)

アクセスを無効にするリソースオーナーの ID。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

#### [](#次の設定の場合-8)次の設定の場合 - [Configuration (設定)](#Config) ## [](#ソース)ソース ### [](#OnTableRow)On Table Row `` ウォーターマークに基づいてテーブルのすべての行を返します。 #### [](#パラメーター-12)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

x

Primary Node Only (プライマリノードのみ)

Boolean (ブール)

クラスターでの Mule インスタンスの実行時、このソースをプライマリノード上でのみ実行するかどうかを決定します。

Scheduling Strategy (スケジュール戦略)

scheduling-strategy

ポーリングをトリガーするスケジューラーを設定します。

x

Redelivery Policy (再配信ポリシー)

同じメッセージの再配信を処理するためのポリシーを定義します。

Dataset Name (データセット名)

String (文字列)

選択元のテーブルの名前。

x

Table Name (テーブル名)

String (文字列)

選択元のテーブルの名前。

x

Watermark Column (ウォーターマーク列)

String (文字列)

ウォーターマークに使用する列の名前。この列から取得された値を使用して次のポーリングのコンテンツが絞り込まれるため、より大きなウォーターマーク値を持つ行のみが処理されます。

Since (以降)

String (文字列)

ウォーターマークとして使用する値。

Column Id (列 ID)

String (文字列)

行 ID とみなす列の名前。このパラメーターを指定することで、同じ行が同時ポーリングによって 2 回処理されないようになります。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。

#### [](#出力-7)出力

型

String (文字列)

Attributes Type (属性型)

#### [](#次の設定の場合-9)次の設定の場合 - [Configuration (設定)](#Config) ## [](#型)型 ### [](#Proxy)Proxy (プロキシ) アウトバウンド接続のプロキシを設定します。
項目 型 説明 デフォルト値 必須

Host (ホスト)

String (文字列)

プロキシサーバーのホスト名または IP アドレス。

x

Port (ポート)

Number (数値)

プロキシサーバーのポート。

x

Username (ユーザー名)

String (文字列)

プロキシサーバーに対して認証するユーザー名。

Password (パスワード)

String (文字列)

プロキシサーバーに対して認証するパスワード。

Non Proxy Hosts (非プロキシホスト)

String (文字列)

プロキシを使用してはならないホストのカンマ区切りリスト。

### [](#Tls)TLS Mule アプリケーションのセキュアな通信を提供するように TLS を設定します。
項目 型 説明 デフォルト値 必須

Enabled Protocols (有効化されたプロトコル)

String (文字列)

このコンテキストで有効化されたプロトコルのカンマ区切りリスト。

Enabled Cipher Suites (有効化された暗号化スイート)

String (文字列)

このコンテキストで有効化された暗号化スイートのカンマ区切りリスト。

トラストストア

TLS トラストストアを設定します。

Key Store (キーストア)

TLS キーストアを設定します。

Revocation Check (取り消し確認)

取り消し確認メカニズムを設定します。

### [](#TrustStore)Truststore (トラストストア) TLS 用のトラストストアを設定します。
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

トラストストアへのパス。Mule では、現在のクラスパスとファイルシステムへの相対的なパスを解決します。

Password (パスワード)

String (文字列)

トラストストアを保護するために使用するパスワード。

Type (型)

String (文字列)

トラストストアの型。

Algorithm (アルゴリズム)

String (文字列)

トラストストアで使用する暗号化アルゴリズム。

Insecure (安全ではない)

Boolean (ブール)

true​ の場合、Mule では証明書の検証の実行を停止します。これを ​true​ に設定すると、接続が攻撃に対して脆弱になる可能性があります。

### [](#KeyStore)Keystore (キーストア) TLS プロトコル用のキーストアを設定します。生成したキーストアには、非公開キーと公開証明書が格納されます。
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

キーストアへのパス。Mule では、現在のクラスパスとファイルシステムへの相対的なパスを解決します。

Type (型)

String (文字列)

キーストアの種別。

Alias (別名)

String (文字列)

キーストアに複数の非公開キーが含まれている場合に使用するキーの別名。デフォルトでは、Mule はファイル内の最初のキーを使用します。

Key Password (キーパスワード)

String (文字列)

非公開キーを保護するために使用するパスワード。

Password (パスワード)

String (文字列)

キーストアを保護するために使用するパスワード。

Algorithm (アルゴリズム)

String (文字列)

キーストアで使用する暗号化アルゴリズム。

### [](#StandardRevocationCheck)Standard Revocation Check (標準の取り消し確認) TLS 証明書の標準取り消し確認を設定します。
項目 型 説明 デフォルト値 必須

Only End Entities (最後のエンティティのみ)

Boolean (ブール)

証明書チェーン内で確認する要素:

  • true​

    証明書チェーンの最後の要素のみを確認します。

  • false​

    証明書チェーンのすべての要素を確認します。

Prefer Crls (CRL を優先)

Boolean (ブール)

証明書の有効性を確認する方法:

  • true​

    証明書失効リスト (CRL) で証明書の有効性を確認します。

  • false​

    オンライン証明書状況プロトコル (OCSP) を使用して証明書の有効性を確認します。

No Fallback (代替なし)

Boolean (ブール)

証明書の有効性を確認するための第 2 の方法を使用するかどうか:

  • true​

    [Prefer Crls (CRL を優先)]​ 項目で指定されていない方法 (第 2 の方法) を使用して証明書の有効性を確認します。

  • false​

    証明書の有効性を確認するための第 2 の方法を使用しません。

Soft Fail (ソフトフェール)

Boolean (ブール)

取り消しサーバーに到達できない場合や取り消しサーバーが混雑している場合の処理:

  • true​

    検証エラーを回避します。

  • false​

    検証の失敗を許可します。

### [](#CustomOcspResponder)Custom OCSP Responder (カスタム OCSP レスポンダー) 証明書の取り消し確認のカスタム OCSP レスポンダーを設定します。
項目 型 説明 デフォルト値 必須

Url

String (文字列)

OCSP レスポンダーの URL。

Cert Alias (証明書の別名)

String (文字列)

OCSP 応答の署名証明書の別名。指定した場合、別名はトラストストアに存在する必要があります。

### [](#CrlFile)CRL File (CRL ファイル) 証明書失効リスト (CRL) ファイルの場所を指定します。
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

CRL ファイルへのパス。

### [](#Reconnection)Reconnection (再接続) 操作の再接続戦略を設定します。
項目 型 説明 デフォルト値 必須

Fails Deployment (デプロイメントに失敗)

Boolean (ブール)

アプリケーションのデプロイ時に、関連する再接続戦略をすべて実行した後、接続テストに合格しない場合の処理:

  • true​

    デプロイメントの失敗を許可します。

  • false​

    接続テストの結果を無視します。

Reconnection Strategy (再接続戦略)

使用する再接続戦略。

### [](#Reconnect)Reconnect (再接続) 標準再接続戦略を設定し、再接続の頻度と、コネクタソースまたは操作で実行できる再接続の試行回数を指定します。
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続を試行する頻度 (ミリ秒)。

Blocking

Boolean (ブール)

false​ の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

Count (数)

Number (数値)

Mule アプリケーションで実行できる再接続の試行回数。

### [](#ReconnectForever)Reconnect Forever (繰り返し再接続) Mule アプリケーションが実行されている間はコネクタソースや操作によって指定された頻度で再接続が試行される Forever 再接続戦略を設定します。
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続を試行する頻度 (ミリ秒)。

Blocking

Boolean (ブール)

false​ の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

### [](#ExpirationPolicy)Expiration Policy (有効期限ポリシー) 有効期限ポリシー戦略を設定します。
項目 型 説明 デフォルト値 必須

Max Idle Time (最大アイドル時間)

Number (数値)

動的設定インスタンスがアイドル状態を続けられる最大時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。

Time Unit (時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

[Max Idle Time (最大アイドル時間)]​ 項目の時間単位。

### [](#HttpResponseAttributes)HTTP Response Attributes (HTTP 応答属性) 設定の HTTP 応答属性を設定します。
項目 型 説明 デフォルト値 必須

Status Code (状況コード)

Number (数値)

応答の HTTP 状況コード。

x

Headers (ヘッダー)

Object (オブジェクト)

メッセージ内の HTTP ヘッダーのマッピング。

x

Reason Phrase (理由を示す語句)

String (文字列)

応答の HTTP の理由を示す語句。

x

### [](#RedeliveryPolicy)Redelivery Policy (再配信ポリシー) エラーを生成する要求を実行するための再配信ポリシーを設定します。再配信ポリシーは、フロー内のあらゆる提供元に追加できます。
項目 型 説明 デフォルト値 必須

Max Redelivery Count (最大再配信数)

Number (数値)

再配信される要求の最大処理失敗回数。この回数を超えると、​REDELIVERY_EXHAUSTED​ エラーが返されます。

Message Digest Algorithm (メッセージダイジェストアルゴリズム)

String (文字列)

[Use Secure Hash (セキュアハッシュを使用)]​ 項目が ​true​ の場合に使用するセキュアハッシュアルゴリズム。メッセージのペイロードが Java オブジェクトの場合、Mule ではこの値が無視され、ペイロードの ​hashCode()​ が返した値が返されます。

Message Identifier (メッセージ識別子)

メッセージが再配信されたかどうかを判断する 1 つ以上の式。このプロパティは、​[Use Secure Hash (セキュアハッシュを使用)]​ 項目が ​false​ の場合にのみ設定できます。

Object Store (オブジェクトストア)

ObjectStore

各メッセージの再配信カウンターが保存されるオブジェクトストアを設定します。

### [](#RedeliveryPolicyMessageIdentifier)Redelivery Policy Message Identifier (再配信ポリシーメッセージ識別子) 再配信されたメッセージを識別する方法と、メッセージがいつ再配信されたのかを見つける方法を設定します。
項目 型 説明 デフォルト値 必須

Use Secure Hash (セキュアハッシュを使用)

Boolean (ブール)

true​ の場合、Mule では再配信されたメッセージの識別にセキュアハッシュアルゴリズムを使用します。

Id Expression (ID 式)

String (文字列)

メッセージがいつ再配信されたのかを判断する 1 つ以上の式。このプロパティは、​[Use Secure Hash (セキュアハッシュを使用)]​ 項目が ​false​ の場合にのみ設定できます。

### [](#RepeatableInMemoryStream)Repeatable In Memory Stream (反復可能なメモリ内ストリーム) データが最大バッファサイズを超えた場合に要求が失敗するメモリ内ストリーミング戦略を設定します。ユースケースで最適なバッファサイズは、必ずパフォーマンステストを実施して決めてください。
項目 型 説明 デフォルト値 必須

Initial Buffer Size (初期バッファサイズ)

Number (数値)

データストリームに割り当てるメモリの初期容量。ストリーミングされたデータがこの値を超える場合は、​[Buffer Size Increment (バッファサイズ増分)]​ の単位で ​[Max In Memory Size (最大メモリ内サイズ)]​ 値を上限としてバッファが拡張されます。

Buffer Size Increment (バッファサイズ増分)

Number (数値)

バッファサイズが初期サイズを超えた場合に、拡張する量。値を ​0​ またはそれ以下に設定すると、バッファは拡張されません。

Max Buffer Size (最大バッファサイズ)

Number (数値)

使用するメモリの最大量。これを超えると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。0 以下の値は無制限を意味します。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Initial Buffer Size (初期バッファサイズ)]​ 項目、​[Buffer Size Increment (バッファサイズ増分)]​ 項目、​[Buffer Unit (バッファ単位)]​ 項目の単位。

### [](#RepeatableFileStoreStream)Repeatable File Store Stream (反復可能なファイルストアストリーム) 反復可能なファイルストアストリーミング戦略を設定します。この戦略では、ストリームコンテンツの一部がメモリ内に格納されます。ストリームのコンテンツが、設定されたバッファサイズよりも大きい場合、Mule はバッファのコンテンツをディスクにバックアップしてからメモリをクリアします。
項目 型 説明 デフォルト値 必須

In Memory Size (メモリ内サイズ)

Number (数値)

ストリームのデータで使用できるメモリの最大量。メモリ量がこの値を超えると、コンテンツはディスクにバッファされます。パフォーマンスを最適化する方法は、次のとおりです。

  • バッファサイズを大きくすると、Mule がバッファをディスクに書き込む回数を減らせます。これによってパフォーマンスが高まりますが、より多くのメモリが必要になるため、アプリケーションが処理できる同時要求数が制限されます。

  • バッファサイズを小さくすると、メモリの負荷は低減しますが、応答時間が長くなります。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[In Memory Size (メモリ内サイズ)]​ 項目の単位。

### [](#RepeatableInMemoryIterable)Repeatable In Memory Iterable (反復可能なメモリ内イテラブル)
項目 型 説明 デフォルト値 必須

Initial Buffer Size (初期バッファサイズ)

Number (数値)

ストリームをコンシュームし、ランダムアクセスを提供するために、最初にメモリ内に保持するインスタンスの量。ストリームのデータ量がこのバッファサイズを超える場合は、​[Buffer Size Increment (バッファサイズ増分)]​ 属性に従って、​[Max In Memory Size (最大メモリ内サイズ)]​ を上限としてバッファが拡張されます。デフォルト値は 100 インスタンスです。

Buffer Size Increment (バッファサイズ増分)

Number (数値)

バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を ​0​ 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。デフォルト値は 100 インスタンスです。

Max Buffer Size (最大バッファサイズ)

Number (数値)

使用するメモリの最大量。これを超えると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。​0​ 以下の値は無制限を意味します。

### [](#RepeatableFileStoreIterable)Repeatable File Store Iterable (反復可能なファイルストアイテラブル)
項目 型 説明 デフォルト値 必須

In Memory Objects (メモリ内オブジェクト)

Number (数値)

メモリ内に保持されるインスタンスの最大数。これ以上の量が必要な場合、ディスク上のコンテンツがバッファされます。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[In Memory Size (メモリ内サイズ)]​ 項目の単位。

## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com)