コネクタパイプラインの更新（Update connector pipeline）

コネクタパイプラインAPIの更新

この機能はベータ版であり、変更される可能性があります。設計とコードは公式GA機能よりも成熟しておらず、保証なしでそのまま提供されています。ベータ機能は公式GA機能のサポートSLAの対象外です。

コネクタのpipeline設定を更新します。

新しいコネクタを作成すると、インジェストパイプラインの設定はデフォルト設定で自動的に設定されます。

コネクタAPIを始めるには、チュートリアルを確認してください。

リクエスト

PUT _connector/<connector_id>/_pipeline

前提条件

• 自己管理のコネクタを使用してデータを同期するには、独自のインフラストラクチャにElasticコネクタサービスをデプロイする必要があります。このサービスは、ネイティブコネクタ用にElastic Cloud上で自動的に実行されます。
• connector_idパラメータは、既存のコネクタを参照する必要があります。

パスパラメータ

• <connector_id>
• （必須、文字列）

リクエストボディ

• pipeline
• （必須、オブジェクト）コネクタのパイプライン設定。パイプラインは、Elasticsearchへのインジェスト中にデータがどのように処理されるかを決定します。

パイプライン設定には、以下の属性が含まれている必要があります：

• extract_binary_content（必須、ブール値）インジェスト中にバイナリコンテンツを抽出するかどうかを示すフラグ。
• name（必須、文字列）インジェストパイプラインの名前。
• reduce_whitespace（必須、ブール値）インジェストされたコンテンツの余分な空白を削減するかどうかを示すフラグ。
• run_ml_inference（必須、ブール値）インジェストされたコンテンツに対して機械学習推論を実行するかどうかを示すフラグ。

レスポンスコード

• 200
• コネクタpipelineフィールドが正常に更新されました。
• 400
• connector_idが提供されていないか、リクエストペイロードが不正です。
• 404（リソースが不足しています）
• connector_idに一致するコネクタが見つかりませんでした。

例

次の例は、ID my-connectorのコネクタのpipelineプロパティを更新します。

Python

resp = client.connector.update_pipeline(
   connector_id="my-connector",
   pipeline={
   "extract_binary_content": True,
   "name": "my-connector-pipeline",
   "reduce_whitespace": True,
   "run_ml_inference": True
   },
)
print(resp)

Ruby

response = client.connector.update_pipeline(
  connector_id: 'my-connector',
  body: {
   pipeline: {
   extract_binary_content: true,
   name: 'my-connector-pipeline',
   reduce_whitespace: true,
   run_ml_inference: true
   }
  }
)
puts response

Js

const response = await client.connector.updatePipeline({
  connector_id: "my-connector",
  pipeline: {
   extract_binary_content: true,
   name: "my-connector-pipeline",
   reduce_whitespace: true,
   run_ml_inference: true,
  },
});
console.log(response);

コンソール

PUT _connector/my-connector/_pipeline
{
   "pipeline": {
   "extract_binary_content": true,
   "name": "my-connector-pipeline",
   "reduce_whitespace": true,
   "run_ml_inference": true
   }
}

コンソール-結果

{
   "result": "updated"
}