Skip to main content

worker_configurations

Creates, updates, deletes, gets or lists a worker_configurations resource.

Overview

Nameworker_configurations
TypeResource
Idaws.kafkaconnect.worker_configurations

Fields

The following fields are returned by SELECT queries:

NameDatatypeDescription
namestringThe name of the worker configuration.
creation_timestring (date-time)The time that the worker configuration was created.
descriptionstringThe description of the worker configuration.
latest_revisionobjectThe latest revision of the custom configuration.
worker_configuration_arnstringThe Amazon Resource Name (ARN) of the custom configuration.
worker_configuration_statestringThe state of the worker configuration. (ACTIVE, DELETING)

Methods

The following methods are available for this resource:

NameAccessible byRequired ParamsOptional ParamsDescription
describe_worker_configurationselectworker_configuration_arn, regionReturns information about a worker configuration.
list_worker_configurationsselectregionmaxResults, nextToken, namePrefixReturns a list of all of the worker configurations in this account and Region.
create_worker_configurationinsertregion, name, propertiesFileContentCreates a worker configuration using the specified properties.
delete_worker_configurationdeleteworker_configuration_arn, regionDeletes the specified worker configuration.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

NameDatatypeDescription
regionstringAWS region (default: us-east-1)
worker_configuration_arnstringThe Amazon Resource Name (ARN) of the worker configuration that you want to delete.
maxResultsintegerThe maximum number of worker configurations to list in one response.
namePrefixstringLists worker configuration names that start with the specified text string.
nextTokenstringIf the response of a ListWorkerConfigurations operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.

SELECT examples

Returns information about a worker configuration.

SELECT
name,
creation_time,
description,
latest_revision,
worker_configuration_arn,
worker_configuration_state
FROM aws.kafkaconnect.worker_configurations
WHERE worker_configuration_arn = '{{ worker_configuration_arn }}' -- required
AND region = '{{ region }}' -- required
;

INSERT examples

Creates a worker configuration using the specified properties.

INSERT INTO aws.kafkaconnect.worker_configurations (
description,
name,
propertiesFileContent,
tags,
region
)
SELECT
'{{ description }}',
'{{ name }}' /* required */,
'{{ propertiesFileContent }}' /* required */,
'{{ tags }}',
'{{ region }}'
RETURNING
name,
creation_time,
latest_revision,
worker_configuration_arn,
worker_configuration_state
;

DELETE examples

Deletes the specified worker configuration.

DELETE FROM aws.kafkaconnect.worker_configurations
WHERE worker_configuration_arn = '{{ worker_configuration_arn }}' --required
AND region = '{{ region }}' --required
;