Apache Spark StreamingのtGSConfigurationプロパティ
これらのプロパティは、Spark Streamingジョブのフレームワークで実行されているtGSConfigurationを設定するために使われます。
Spark StreamingのtGSConfigurationコンポーネントは、ストレージファミリーに属しています。
このコンポーネントはTalend Real-Time Big Data PlatformとTalend Data Fabricで利用できます。
基本設定
このコンポーネントをGoogle Dataprocと併用する場合:
|
[Google Storage bucket] (Googleストレージバケット) |
ジョブ全体で使用するバケットの名前を入力します。次に、tFileInputDelimitedまたはtFileOutputDelimitedなど、Fileのコンポーネントでは、このバケットのディレクトリーが使用されます。 たとえば、このフィールドにmy_bucketと入力し、tFileInputDelimitedの[Folder] (フォルダー)フィールドに/user/ychenを入力すると、tFileInputDelimitedによってgs://my_bucket/user/ychenからデータが読み取られます。 |
このコンポーネントをその他のディストリビューションと併用する場合:
|
[Project ID] (プロジェクトID) |
Google Cloud PlatformプロジェクトのIDを入力します。 プロジェクトIDがわからない場合は、Google Cloud Platformサービスの[Manage Resources]ページでご確認ください。 |
|
[Google Storage bucket] (Googleストレージバケット) |
ジョブ全体で使用するバケットの名前を入力します。次に、tFileInputDelimitedまたはtFileOutputDelimitedなど、Fileのコンポーネントでは、このバケットのディレクトリーが使用されます。 たとえば、このフィールドにmy_bucketと入力し、tFileInputDelimitedの[Folder] (フォルダー)フィールドに/user/ychenを入力すると、tFileInputDelimitedによってgs://my_bucket/user/ychenからデータが読み取られます。 |
|
[Use P12 credentials file format] (P12認証情報ファイル形式を使用) |
使用するGoogleクレデンシャルファイルがP12形式の場合は、このチェックボックスを選択し、表示される[Service account Id] (サービスアカウントID)フィールドにP12認証情報ファイルが作成されたサービスアカウントのIDを入力します。 |
|
[Path to Google Credentials file] (Googleクレデンシャルファイルへのパス) |
使用するユーザーアカウントに関連付けられている認証情報ファイルのパスを入力します。このファイルはTalendジョブが実際に起動および実行されるコンピューターに保管されている必要があります。 Talend JobServerを使用してジョブを実行する場合、ジョブを起動するTalend JobServerのマシンだけでなく、ジョブを実行するSparkクラスターのワーカーマシンにも認証情報ファイルを保管します。Talend JobServerを使用しない場合は、ジョブを起動するローカルマシンとSparkクラスターのワーカーマシンに認証情報ファイルを保管します。 |
グローバル変数
|
グローバル変数 |
ERROR_MESSAGE: エラーが発生した時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。この変数はコンポーネントにこのチェックボックスが存在し、[Die on error] (エラー発生時に強制終了)がオフになっている場合のみ機能します。 Flow変数はのコンポーネントの実行中に機能し、After変数はコンポーネントの実行後に機能します。 フィールドまたは式に変数を入力する場合は、Ctrl + スペースを押して変数リストにアクセスし、使用する変数を選択します。 変数の詳細は、コンテキストと変数を使用をご覧ください。 |
使用方法
|
使用ルール |
Google Storageへの接続設定を行う場合は、1つのジョブで複数のtGSConfigurationコンポーネントを使用できます。 たとえば1つのジョブで2つのtGSConfigurationコンポーネントを使い、認証情報が異なる別々のGoogle Storageバケットを使うことも可能です。2つのtGSConfigurationコンポーネントを使うためには、で正しい権限を設定する必要があります。 たとえば次の操作を行っているとします。
Talend Studio 8.0のR2022-12以降、tGSConfigurationが[Local] (ローカル)モードでSpark Universalを、Google Cloud PlatformでDatabricksをサポートするようになりました。 |
|
[Spark Connection] (Spark接続) |
[Run] (実行)ビューの[Spark configuration] (Spark設定)タブで、ジョブ全体でのSparkクラスターへの接続を定義します。また、ジョブでは、依存jarファイルを実行することを想定しているため、Sparkがこれらのjarファイルにアクセスできるように、これらのファイルの転送先にするファイルシステム内のディレクトリーを指定する必要があります。
この接続は、ジョブごとに有効になります。 |