AWS Converse

AWS Converse

Certified

Converse with an Amazon Bedrock foundation model

Sends a structured multi-turn conversation to any Bedrock model using the unified Converse API. Supports system prompts, multi-turn message history, and inference configuration such as max tokens and temperature.

yaml
type: io.kestra.plugin.aws.bedrock.Converse

Structured chat with Claude via the Bedrock Converse API

yaml
id: bedrock_converse
namespace: company.team

inputs:
  - id: user_message
    type: STRING

tasks:
  - id: chat
    type: io.kestra.plugin.aws.bedrock.Converse
    region: "{{ secret('AWS_REGION') }}"
    accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
    secretKeyId: "{{ secret('AWS_SECRET_ACCESS_KEY') }}"
    modelId: "anthropic.claude-3-5-sonnet-20241022-v2:0"
    messages:
      - role: user
        content: "{{ inputs.user_message }}"
    system: "You are a concise data engineering assistant."
    inferenceConfig:
      maxTokens: 1024

  - id: log_reply
    type: io.kestra.plugin.core.log.Log
    message: "Assistant: {{ outputs.chat.content }}"
Properties
SubTypeobject
Min items1

Messages

Ordered list of conversation turns. Each entry must have a role (user or assistant) and content (text string).

Model ID

The Bedrock model identifier, e.g. anthropic.claude-3-5-sonnet-20241022-v2: 0.

Access Key Id in order to connect to AWS

If no credentials are defined, we will use the default credentials provider chain to fetch credentials.

Enable compatibility mode

Use it to connect to S3 bucket with S3 compatible services that don't support the new transport client.

The endpoint with which the SDK should communicate

This property allows you to use a different S3 compatible storage backend.

Force path style access

Must only be used when compatibilityMode is enabled.

Inference configuration

Optional inference parameters. Supported keys: maxTokens (integer), temperature (float 0–1), topP (float 0–1), stopSequences (list of strings).

Reference (ref) of the pluginDefaults to apply to this task.

AWS region with which the SDK should communicate

Secret Key Id in order to connect to AWS

If no credentials are defined, we will use the default credentials provider chain to fetch credentials.

AWS session token, retrieved from an AWS token service, used for authenticating that this user has received temporary permissions to access a given resource

If no credentials are defined, we will use the default credentials provider chain to fetch credentials.

The AWS STS endpoint with which the SDKClient should communicate

AWS STS Role

The Amazon Resource Name (ARN) of the role to assume. If set the task will use the StsAssumeRoleCredentialsProvider. If no credentials are defined, we will use the default credentials provider chain to fetch credentials.

AWS STS External Id

A unique identifier that might be required when you assume a role in another account. This property is only used when an stsRoleArn is defined.

DefaultPT15M

AWS STS Session duration

The duration of the role session (default: 15 minutes, i.e., PT15M). This property is only used when an stsRoleArn is defined.

AWS STS Session name

This property is only used when an stsRoleArn is defined.

System prompt

Optional system-level instruction prepended before the conversation.

Content

The assistant's text reply.

Input tokens

Number of input tokens consumed.

Model ID

The model that was invoked.

Output tokens

Number of output tokens generated.

Stop reason

Why the model stopped generating tokens, e.g. end_turn or max_tokens.