Pipes

This page documents function available when using the Pipes module, created with @service Pipes.

Index

Documentation

Main.Pipes.create_pipeMethod
create_pipe(name, role_arn, source, target)
create_pipe(name, role_arn, source, target, params::Dict{String,<:Any})

Create a pipe. Amazon EventBridge Pipes connect event sources to targets and reduces the need for specialized knowledge and integration code.

Arguments

  • name: The name of the pipe.
  • role_arn: The ARN of the role that allows the pipe to send data to the target.
  • source: The ARN of the source resource.
  • target: The ARN of the target resource.

Optional Parameters

Optional parameters can be passed as a params::Dict{String,<:Any}. Valid keys are:

  • "Description": A description of the pipe.
  • "DesiredState": The state the pipe should be in.
  • "Enrichment": The ARN of the enrichment resource.
  • "EnrichmentParameters": The parameters required to set up enrichment on your pipe.
  • "SourceParameters": The parameters required to set up a source for your pipe.
  • "Tags": The list of key-value pairs to associate with the pipe.
  • "TargetParameters": The parameters required to set up a target for your pipe.
source
Main.Pipes.delete_pipeMethod
delete_pipe(name)
delete_pipe(name, params::Dict{String,<:Any})

Delete an existing pipe. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Arguments

  • name: The name of the pipe.
source
Main.Pipes.describe_pipeMethod
describe_pipe(name)
describe_pipe(name, params::Dict{String,<:Any})

Get the information about an existing pipe. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Arguments

  • name: The name of the pipe.
source
Main.Pipes.list_pipesMethod
list_pipes()
list_pipes(params::Dict{String,<:Any})

Get the pipes associated with this account. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Optional Parameters

Optional parameters can be passed as a params::Dict{String,<:Any}. Valid keys are:

  • "CurrentState": The state the pipe is in.
  • "DesiredState": The state the pipe should be in.
  • "Limit": The maximum number of pipes to include in the response.
  • "NamePrefix": A value that will return a subset of the pipes associated with this account. For example, "NamePrefix": "ABC" will return all endpoints with "ABC" in the name.
  • "NextToken": If nextToken is returned, there are more results available. The value of nextToken is a unique pagination token for each page. Make the call again using the returned token to retrieve the next page. Keep all other arguments unchanged. Each pagination token expires after 24 hours. Using an expired pagination token will return an HTTP 400 InvalidToken error.
  • "SourcePrefix": The prefix matching the pipe source.
  • "TargetPrefix": The prefix matching the pipe target.
source
Main.Pipes.list_tags_for_resourceMethod
list_tags_for_resource(resource_arn)
list_tags_for_resource(resource_arn, params::Dict{String,<:Any})

Displays the tags associated with a pipe.

Arguments

  • resource_arn: The ARN of the pipe for which you want to view tags.
source
Main.Pipes.start_pipeMethod
start_pipe(name)
start_pipe(name, params::Dict{String,<:Any})

Start an existing pipe.

Arguments

  • name: The name of the pipe.
source
Main.Pipes.stop_pipeMethod
stop_pipe(name)
stop_pipe(name, params::Dict{String,<:Any})

Stop an existing pipe.

Arguments

  • name: The name of the pipe.
source
Main.Pipes.tag_resourceMethod
tag_resource(resource_arn, tags)
tag_resource(resource_arn, tags, params::Dict{String,<:Any})

Assigns one or more tags (key-value pairs) to the specified pipe. Tags can help you organize and categorize your resources. You can also use them to scope user permissions by granting a user permission to access or change only resources with certain tag values. Tags don't have any semantic meaning to Amazon Web Services and are interpreted strictly as strings of characters. You can use the TagResource action with a pipe that already has tags. If you specify a new tag key, this tag is appended to the list of tags associated with the pipe. If you specify a tag key that is already associated with the pipe, the new tag value that you specify replaces the previous value for that tag. You can associate as many as 50 tags with a pipe.

Arguments

  • resource_arn: The ARN of the pipe.
  • tags: The list of key-value pairs associated with the pipe.
source
Main.Pipes.untag_resourceMethod
untag_resource(resource_arn, tag_keys)
untag_resource(resource_arn, tag_keys, params::Dict{String,<:Any})

Removes one or more tags from the specified pipes.

Arguments

  • resource_arn: The ARN of the pipe.
  • tag_keys: The list of tag keys to remove from the pipe.
source
Main.Pipes.update_pipeMethod
update_pipe(name, role_arn)
update_pipe(name, role_arn, params::Dict{String,<:Any})

Update an existing pipe. When you call UpdatePipe, only the fields that are included in the request are changed, the rest are unchanged. The exception to this is if you modify any Amazon Web Services-service specific fields in the SourceParameters, EnrichmentParameters, or TargetParameters objects. The fields in these objects are updated atomically as one and override existing values. This is by design and means that if you don't specify an optional field in one of these Parameters objects, that field will be set to its system-default value after the update. For more information about pipes, see Amazon EventBridge Pipes in the Amazon EventBridge User Guide.

Arguments

  • name: The name of the pipe.
  • role_arn: The ARN of the role that allows the pipe to send data to the target.

Optional Parameters

Optional parameters can be passed as a params::Dict{String,<:Any}. Valid keys are:

  • "Description": A description of the pipe.
  • "DesiredState": The state the pipe should be in.
  • "Enrichment": The ARN of the enrichment resource.
  • "EnrichmentParameters": The parameters required to set up enrichment on your pipe.
  • "SourceParameters": The parameters required to set up a source for your pipe.
  • "Target": The ARN of the target resource.
  • "TargetParameters": The parameters required to set up a target for your pipe.
source