Add Batch Prediction Mode in the Connector Framework for batch inference

[Zhangxunmt]

Description

Add the batch mode in the connector to support offline batch inference.

POST /_plugins/_ml/connectors/_create
{
 ...
"actions": [
    {
      "action_type": "predict",
      "method": "POST",
      "headers": {
        "content-type": "application/json"
      },
      "url": <your realtime endpoint url>,
      "request_body": "${parameters.input}",
      "pre_process_function": "connector.pre_process.default.embedding",
      "post_process_function": "connector.post_process.default.embedding"
    },
    {
        "action_type": "batch",
        "method": "POST",
        "headers": {
            "content-type": "application/json"
        },
        "url": "https://api.sagemaker.<your region>.amazonaws.com/CreateTransformJob",
        "request_body": "{ \"BatchStrategy\": \"${parameters.BatchStrategy}\", \"ModelName\": \"${parameters.ModelName}\", \"DataProcessing\" : ${parameters.DataProcessing}, \"TransformInput\": ${parameters.TransformInput}, \"TransformJobName\" : \"${parameters.TransformJobName}\", \"TransformOutput\" : ${parameters.TransformOutput}, \"TransformResources\" : ${parameters.TransformResources}}"
    }
  ]
}

Invoke the offline mode batch prediction

POST /_plugins/_ml/models/dBK3t5ABrxVhHgFYhg7Q/_batch_prediction
{
  "parameters": {
    "TransformJobName": "unique name"
  }
}

Invoke the realtime predict

POST /_plugins/_ml/models/dBK3t5ABrxVhHgFYhg7Q/_predict
{
  "parameters": {
    "input" : ["test1", "test2"]
  }
}

Issues Resolved

#2488

Check List

• New functionality includes testing.
  • All tests pass
• New functionality has been documented.
  • New functionality has javadoc added
• Commits are signed per the DCO using --signoff

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
For more information on following Developer Certificate of Origin and signing off your commits, please check here.

[dhrubo-os]

remove this? or use log?

[Zhangxunmt]

Already removed. But don't want to waste time running CI again. Will include the removal in my next PR.

[dhrubo-os]

same here?

[opensearch-trigger-bot]

The backport to 2.x failed:

The process '/usr/bin/git' failed with exit code 1

To backport manually, run these commands in your terminal:

# Fetch latest updates from GitHub
git fetch
# Create a new working tree
git worktree add .worktrees/backport-2.x 2.x
# Navigate to the new working tree
cd .worktrees/backport-2.x
# Create a new branch
git switch --create backport/backport-2661-to-2.x
# Cherry-pick the merged commit of this pull request and resolve the conflicts
git cherry-pick -x --mainline 1 39efbe7eda14b995f8c14a1ece06c7eabc453cd2
# Push it to GitHub
git push --set-upstream origin backport/backport-2661-to-2.x
# Go back to the original working tree
cd ../..
# Delete the working tree
git worktree remove .worktrees/backport-2.x

Then, create a pull request where the base branch is 2.x and the compare/head branch is backport/backport-2661-to-2.x.