目次

Search

  1. はじめに
  2. Informatica Intelligent Cloud Services REST API
  3. プラットフォームREST APIバージョン2リソース
  4. プラットフォームREST APIバージョン3リソース
  5. データ統合 REST API
  6. 一括取り込みファイルREST API
  7. 一括取り込みストリーミングREST API
  8. Model Serve REST API
  9. RunAJobユーティリティ
  10. ParamSetCliユーティリティ
  11. REST APIコード
  12. REST APIリソースクイックリファレンス

REST APIリファレンス

REST APIリファレンス

コードタスクの作成

コードタスク
の作成

CodeTaskリソースを使用して
コードタスク
を作成します。応答には、後続のAPI呼び出しで使用できるコードタスクIDが含まれます。

POST要求

次のURIを使用して
コードタスク
を作成します。
POST <server URL>/disnext/api/v1/CodeTask
POST要求で次のフィールドを使用します。
フィールド
タイプ
必須/オプション
説明
codeTaskName
String
必須
コードタスク
の名前。
runtimeEnvironmentName
String
オプション
コードタスク
に使用されるランタイム環境。
runtimeEnvironmentNameまたはagentGroupIdのいずれかが必要です。両方が指定されている場合は、agentGroupIdが使用されます。
codeExecutionParameters
コードタスク
のパラメータ。
agentGroupId
String
必須
コードタスク
の実行に使用されるSecure Agentを含むランタイム環境。
runtimeEnvironmentNameまたはagentGroupIdのいずれかが必要です。両方が指定されている場合は、agentGroupIdが使用されます。
overrideTaskTimeout
Long
オプション
この実行のコードタスクタイムアウト値をオーバーライドします。値-1は、タイムアウトがないことを意味します。
logLevel
String
オプション
セッションログ、エージェントジョブログ、Sparkドライバ、およびエグゼキューターログのログレベル。有効な値は、none、terse、normal、verboseInitialization、またはverboseDataです。
デフォルト値はnormalです。
sparkMainClass
String
必須
Sparkアプリケーションのエントリポイント。以下に例を示します。
org.apache.spark.examples.company.SparkExampleApp
sparkMainClassArgs
List <String>
オプション
SparkアプリケーションのMainクラスに送信される順序付けされた引数。以下に例を示します。
--appTypeSPARK_PI_FILES_JARS--
classesToLoadcom.company.test.SparkTest1Class
sparkPrimaryResource
String
必須
コードタスク
が含まれているScala JARファイル。
sparkJars
List <String>
オプション
クラスタにアップロードされ、Sparkドライバとエグゼキュータークラスパスに追加されるJARファイルのディレクトリとファイル名。
sparkFiles
List <String>
オプション
クラスタにアップロードされ、現在の作業ディレクトリで利用できるSparkファイルのディレクトリとファイル名。
advancedCustomProperties
String
オプション
データ統合
が使用するSparkプロパティまたはその他のカスタムプロパティ。以下に例を示します。
"{\"spark.driver.memory\": \"2G\", \"spark.executor.instances\": \"4\"}"

POST応答

次の変数は応答属性から設定されます。
名前
応答値
CODE_TASK_ID
codeTaskId
コードタスク
のstartリソースとviewリソースで使用されます。

POST要求の例

コードタスク
を作成するには、次のサンプルを参考にしてください。
POST <server URL>/disnext/api/v1/CodeTask Content-Type: application/json Accept: application/json IDS-SESSION-ID:{{IDS_SESSION_ID}} { "codeTaskName" : "CODETASK_API", "runtimeEnvironmentName" : "{{RTE_NAME}}", "codeExecutionParameters" : { "agentGroupId": "{{AGENT_GROUP_ID}}", "logLevel": "normal", "sparkMainClass": "org.apache.spark.examples.infa.sparkdirect.SparkDirectExampleApp", "sparkMainClassArgs": ["6"], "sparkPrimaryResource": "spark-examples_2.12-3.0.0.jar", "sparkJars": [], "sparkFiles": [], "advancedCustomProperties": "{\"spark.driver.memory\": \"1G\", \"spark.executor.memory\": \"1G\", \"spark.kubernetes.driverEnv.SPARK_DIRECT_TASK_SLEEP\": \"600\", \"spark.kubernetes.driverEnv.SPARK_DIRECT_APP_TYPE\": \"SPARK_PI\", \"spark.kubernetes.driverEnv.SPARK_DIRECT_KMS_ENCRYPTED_PROPS\": \"spark.sparkdirect.kms.prop\", \"spark.sparkdirect.kms.prop\": \"5pkOjS0HILDwSaW6eyxtiwB3g2TBYayjKLRFSSyxn5M=0p6v3eCvrtFkw6K78Buwal\", \"advanced.custom.property\": \"infa.spark.local=false\"}" } }

POST応答の例

POST応答が成功すると、次の例のようなサマリ、
コードタスク
ID、および
コードタスク
名が返されます。
{ "summary": "Code Task created successfully", "codeTaskId": 3, "codeTaskName": "CODETASK_API" }