Variable KinesisDataStreamSchemaConst
KinesisDataStreamSchema: ZodObject<
{
eventSourceARN: ZodOptional<ZodString>;
isFinalInvokeForWindow: ZodOptional<ZodBoolean>;
isWindowTerminatedEarly: ZodOptional<ZodBoolean>;
Records: ZodArray<
ZodObject<
{
awsRegion: ZodString;
eventID: ZodString;
eventName: ZodLiteral<"aws:kinesis:record">;
eventSource: ZodLiteral<"aws:kinesis">;
eventSourceARN: ZodString;
eventVersion: ZodString;
invokeIdentityArn: ZodString;
kinesis: ZodObject<
{
approximateArrivalTimestamp: ZodNumber;
data: ZodEffects<ZodString, any, string>;
kinesisSchemaVersion: ZodString;
partitionKey: ZodString;
sequenceNumber: ZodString;
},
"strip",
ZodTypeAny,
{
approximateArrivalTimestamp: number;
data?: any;
kinesisSchemaVersion: string;
partitionKey: string;
sequenceNumber: string;
},
{
approximateArrivalTimestamp: number;
data: string;
kinesisSchemaVersion: string;
partitionKey: string;
sequenceNumber: string;
},
>;
},
"strip",
ZodTypeAny,
{
awsRegion: string;
eventID: string;
eventName: "aws:kinesis:record";
eventSource: "aws:kinesis";
eventSourceARN: string;
eventVersion: string;
invokeIdentityArn: string;
kinesis: {
approximateArrivalTimestamp: number;
data?: any;
kinesisSchemaVersion: string;
partitionKey: string;
sequenceNumber: string;
};
},
{
awsRegion: string;
eventID: string;
eventName: "aws:kinesis:record";
eventSource: "aws:kinesis";
eventSourceARN: string;
eventVersion: string;
invokeIdentityArn: string;
kinesis: {
approximateArrivalTimestamp: number;
data: string;
kinesisSchemaVersion: string;
partitionKey: string;
sequenceNumber: string;
};
},
>,
"many",
>;
shardId: ZodOptional<ZodString>;
state: ZodOptional<ZodRecord<ZodString, ZodUnknown>>;
window: ZodOptional<
ZodObject<
{ end: ZodString; start: ZodString },
"strip",
ZodTypeAny,
{ end: string; start: string },
{ end: string; start: string },
>,
>;
},
"strip",
ZodTypeAny,
{
eventSourceARN?: string;
isFinalInvokeForWindow?: boolean;
isWindowTerminatedEarly?: boolean;
Records: {
awsRegion: string;
eventID: string;
eventName: "aws:kinesis:record";
eventSource: "aws:kinesis";
eventSourceARN: string;
eventVersion: string;
invokeIdentityArn: string;
kinesis: {
approximateArrivalTimestamp: number;
data?: any;
kinesisSchemaVersion: string;
partitionKey: string;
sequenceNumber: string;
};
}[];
shardId?: string;
state?: Record<string, unknown>;
window?: { end: string; start: string };
},
{
eventSourceARN?: string;
isFinalInvokeForWindow?: boolean;
isWindowTerminatedEarly?: boolean;
Records: {
awsRegion: string;
eventID: string;
eventName: "aws:kinesis:record";
eventSource: "aws:kinesis";
eventSourceARN: string;
eventVersion: string;
invokeIdentityArn: string;
kinesis: {
approximateArrivalTimestamp: number;
data: string;
kinesisSchemaVersion: string;
partitionKey: string;
sequenceNumber: string;
};
}[];
shardId?: string;
state?: Record<string, unknown>;
window?: { end: string; start: string };
},
> = ...
Zod schema for Kinesis Data Stream event