com.mozilla.secops

Class SqsIO

java.lang.Object

com.mozilla.secops.SqsIO

public class SqsIO
extends Object

SqsIO provides an IO transform for writing messages to SQS

Although an SQS output transform exists in the standard Beam SDK this differs slightly in that it supports per-invocation AWS credentials, and does not rely on global pipeline option based AWS credential specification.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SqsIO.Write

Constructor Summary

Constructors

Constructor and Description
SqsIO()

Method Summary

Modifier and Type	Method and Description
static String[]	parseQueueInfo(String input) Parse an input queue specification, returning each element
static SqsIO.Write	write(String sqsQueueInfo, String project) Return PTransform to write messages to SQS

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SqsIO

public SqsIO()

Method Detail

parseQueueInfo

public static String[] parseQueueInfo(String input)

Parse an input queue specification, returning each element

The expected format is queueurl:accesskey:secret:region

Parameters:

input - Input string

Returns:

Output array containing each element, or null if invalid

write

public static SqsIO.Write write(String sqsQueueInfo,
                                String project)

Return PTransform to write messages to SQS

Parameters:

sqsQueueInfo - SQS queue information, url:key:secret:region

project - GCP project name, only required if decrypting queue infomration via cloudkms

Returns:

IO transform