Skip to content

Instantly share code, notes, and snippets.

@Bryji
Bryji / FetchDynamoItems.scala
Created July 12, 2022 15:07
Recursively fetch dynamo items chaining CompleteableFutures and wrap in Async[F]
type DynamoItems = util.List[util.Map[String, AttributeValue]]
val client: DynamoDbAsyncClient = ???
override def getByDeviceGuid(tableName: String, deviceGuid: String, consistentRead: Boolean)(implicit
traceContext: TraceContext
): F[DynamoItems] = {
val attributeValues = Map(":deviceGuidValue" -> AttributeValue.builder().s(deviceGuid).build()).asJava
val getAllRequest = QueryRequest
.builder()
@Bryji
Bryji / KinesisFirehoseEvent.java
Last active November 25, 2021 18:32
Kinesis Firehose Transformation Lambda objects in Java (do not seem to be provided for in an AWS SDK for now!)
mport java.util.List;
public class KinesisFirehoseEvent {
String invocationId;
String deliveryStreamArn;
String region;
List<KinesisFirehoseInputRecord> records;
public String getInvocationId() {