Variable KinesisFirehoseSqsSchemaConst
KinesisFirehoseSqsSchema: ZodObject<
extendShape<
{
deliveryStreamArn: ZodString;
invocationId: ZodString;
region: ZodString;
sourceKinesisStreamArn: ZodOptional<ZodString>;
},
{
records: ZodArray<
ZodObject<
extendShape<
{
approximateArrivalTimestamp: ZodNumber;
kinesisRecordMetadata: ZodOptional<
ZodNullable<
ZodObject<
{
approximateArrivalTimestamp: ...;
partitionKey: ...;
sequenceNumber: ...;
shardId: ...;
subsequenceNumber: ...;
},
"strip",
ZodTypeAny,
{
approximateArrivalTimestamp: ...;
partitionKey: ...;
sequenceNumber: ...;
shardId: ...;
subsequenceNumber: ...;
},
{
approximateArrivalTimestamp: ...;
partitionKey: ...;
sequenceNumber: ...;
shardId: ...;
subsequenceNumber: ...;
},
>,
>,
>;
recordId: ZodString;
},
{
data: ZodEffects<
ZodString,
{
attributes: {
ApproximateFirstReceiveTimestamp: string;
ApproximateReceiveCount: string;
AWSTraceHeader?: (...)
| (...);
DeadLetterQueueSourceArn?: (...) | (...);
MessageDeduplicationId?: (...) | (...);
MessageGroupId?: (...) | (...);
SenderId: string;
SentTimestamp: string;
SequenceNumber?: (...) | (...);
};
awsRegion: string;
body: string;
eventSource: "aws:sqs";
eventSourceARN: string;
md5OfBody: string;
md5OfMessageAttributes?: null
| string;
messageAttributes: Record<
string,
{
binaryListValues?: ...;
binaryValue?: ...;
dataType: ...;
stringListValues?: ...;
stringValue?: ...;
},
>;
messageId: string;
receiptHandle: string;
},
string,
>;
},
>,
"strip",
ZodTypeAny,
{
approximateArrivalTimestamp: number;
data: {
attributes: {
ApproximateFirstReceiveTimestamp: string;
ApproximateReceiveCount: string;
AWSTraceHeader?: string;
DeadLetterQueueSourceArn?: string;
MessageDeduplicationId?: string;
MessageGroupId?: string;
SenderId: string;
SentTimestamp: string;
SequenceNumber?: string;
};
awsRegion: string;
body: string;
eventSource: "aws:sqs";
eventSourceARN: string;
md5OfBody: string;
md5OfMessageAttributes?: null
| string;
messageAttributes: Record<
string,
{
binaryListValues?: (...)[];
binaryValue?: string;
dataType: string;
stringListValues?: (...)[];
stringValue?: string;
},
>;
messageId: string;
receiptHandle: string;
};
kinesisRecordMetadata?: | null
| {
approximateArrivalTimestamp: number;
partitionKey: string;
sequenceNumber: string;
shardId: string;
subsequenceNumber: number;
};
recordId: string;
},
{
approximateArrivalTimestamp: number;
data: string;
kinesisRecordMetadata?: | null
| {
approximateArrivalTimestamp: number;
partitionKey: string;
sequenceNumber: string;
shardId: string;
subsequenceNumber: number;
};
recordId: string;
},
>,
"many",
>;
},
>,
"strip",
ZodTypeAny,
{
deliveryStreamArn: string;
invocationId: string;
records: {
approximateArrivalTimestamp: number;
data: {
attributes: {
ApproximateFirstReceiveTimestamp: string;
ApproximateReceiveCount: string;
AWSTraceHeader?: string;
DeadLetterQueueSourceArn?: string;
MessageDeduplicationId?: string;
MessageGroupId?: string;
SenderId: string;
SentTimestamp: string;
SequenceNumber?: string;
};
awsRegion: string;
body: string;
eventSource: "aws:sqs";
eventSourceARN: string;
md5OfBody: string;
md5OfMessageAttributes?: null
| string;
messageAttributes: Record<
string,
{
binaryListValues?: string[];
binaryValue?: string;
dataType: string;
stringListValues?: string[];
stringValue?: string;
},
>;
messageId: string;
receiptHandle: string;
};
kinesisRecordMetadata?: | null
| {
approximateArrivalTimestamp: number;
partitionKey: string;
sequenceNumber: string;
shardId: string;
subsequenceNumber: number;
};
recordId: string;
}[];
region: string;
sourceKinesisStreamArn?: string;
},
{
deliveryStreamArn: string;
invocationId: string;
records: {
approximateArrivalTimestamp: number;
data: string;
kinesisRecordMetadata?: | null
| {
approximateArrivalTimestamp: number;
partitionKey: string;
sequenceNumber: string;
shardId: string;
subsequenceNumber: number;
};
recordId: string;
}[];
region: string;
sourceKinesisStreamArn?: string;
},
> = ...
Zod schema for Kinesis Firehose events with SQS records