1 | import { Callback, Handler } from "../handler";
|
2 |
|
3 | export type FirehoseTransformationHandler = Handler<FirehoseTransformationEvent, FirehoseTransformationResult>;
|
4 | export type FirehoseTransformationCallback = Callback<FirehoseTransformationResult>;
|
5 |
|
6 |
|
7 |
|
8 |
|
9 |
|
10 |
|
11 | export interface FirehoseTransformationEvent {
|
12 | invocationId: string;
|
13 | deliveryStreamArn: string;
|
14 | region: string;
|
15 | records: FirehoseTransformationEventRecord[];
|
16 | }
|
17 |
|
18 | export interface FirehoseTransformationEventRecord {
|
19 | recordId: string;
|
20 | approximateArrivalTimestamp: number;
|
21 |
|
22 | data: string;
|
23 | kinesisRecordMetadata?: FirehoseRecordMetadata;
|
24 | }
|
25 |
|
26 | export interface FirehoseRecordMetadata {
|
27 | shardId: string;
|
28 | partitionKey: string;
|
29 | approximateArrivalTimestamp: string;
|
30 | sequenceNumber: string;
|
31 | subsequenceNumber: string;
|
32 | }
|
33 |
|
34 | export type FirehoseRecordTransformationStatus = 'Ok' | 'Dropped' | 'ProcessingFailed';
|
35 |
|
36 | export interface FirehoseTransformationResultRecord {
|
37 | recordId: string;
|
38 | result: FirehoseRecordTransformationStatus;
|
39 |
|
40 | data: string;
|
41 | }
|
42 |
|
43 | export interface FirehoseTransformationResult {
|
44 | records: FirehoseTransformationResultRecord[];
|
45 | }
|