amqp_1

BETA: This component is mostly stable but breaking changes could still be made outside of major version releases if a fundamental problem with the component is found.

Reads messages from an AMQP (1.0) server.

# Common config fields, showing default values
input:
label: ""
amqp_1:
url: ""
source_address: ""

Metadata#

This input adds the following metadata fields to each message:

- amqp_content_type
- amqp_content_encoding
- amqp_creation_time

You can access these metadata fields using function interpolation.

Fields#

url#

A URL to connect to.

Type: string
Default: ""

# Examples
url: amqp://localhost:5672/
url: amqps://guest:guest@localhost:5672/

source_address#

The source address to consume from.

Type: string
Default: ""

# Examples
source_address: /foo
source_address: queue:/bar
source_address: topic:/baz

tls#

Custom TLS settings can be used to override system defaults.

Type: object

tls.enabled#

Whether custom TLS settings are enabled.

Type: bool
Default: false

tls.skip_cert_verify#

Whether to skip server side certificate verification.

Type: bool
Default: false

tls.root_cas_file#

An optional path of a root certificate authority file to use. This is a file, often with a .pem extension, containing a certificate chain from the parent trusted root certificate, to possible intermediate signing certificates, to the host certificate.

Type: string
Default: ""

# Examples
root_cas_file: ./root_cas.pem

tls.client_certs#

A list of client certificates to use. For each certificate either the fields cert and key, or cert_file and key_file should be specified, but not both.

Type: array

# Examples
client_certs:
- cert: foo
key: bar
client_certs:
- cert_file: ./example.pem
key_file: ./example.key

tls.client_certs[].cert#

A plain text certificate to use.

Type: string
Default: ""

tls.client_certs[].key#

A plain text certificate key to use.

Type: string
Default: ""

tls.client_certs[].cert_file#

The path to a certificate to use.

Type: string
Default: ""

tls.client_certs[].key_file#

The path of a certificate key to use.

Type: string
Default: ""

sasl#

Enables SASL authentication.

Type: object

sasl.mechanism#

The SASL authentication mechanism to use.

Type: string
Default: "none"

OptionSummary
noneNo SASL based authentication.
plainPlain text SASL authentication.

sasl.user#

A SASL plain text username. It is recommended that you use environment variables to populate this field.

Type: string
Default: ""

# Examples
user: ${USER}

sasl.password#

A SASL plain text password. It is recommended that you use environment variables to populate this field.

Type: string
Default: ""

# Examples
password: ${PASSWORD}