sqs_output_device

messageflux.iodevices.sqs.sqs_output_device

SQSOutputDevice

SQSOutputDevice(device_manager, queue_name)

Bases: OutputDevice['SQSOutputDeviceManager']

represents an SQS output devices

constructs a new output SQS device

Parameters:

Name	Type	Description	Default
`device_manager`	`SQSOutputDeviceManager`	the SQS device Manager that holds this device	required
`queue_name`	`str`	the name of the queue	required

SQSOutputDeviceManager(sqs_resource=None, **kwargs)

this manager is used to create SQS devices

Parameters:

Name	Type	Description	Default
`sqs_resource`	`Optional[SQSServiceResource]`	the boto sqs service resource. Defaults to creating from env vars	`None`