def METHOD_NAME():
    raw_event = load_event("kinesisStreamEvent.json")
    parsed_event: KinesisDataStreamModel = KinesisDataStreamModel(**raw_event)
    records = parsed_event.Records
    assert len(records) == 2
    record: KinesisDataStreamModel = records[0]
    raw_record = raw_event["Records"][0]
    assert record.awsRegion == raw_record["awsRegion"]
    assert record.eventID == raw_record["eventID"]
    assert record.eventName == raw_record["eventName"]
    assert record.eventSource == raw_record["eventSource"]
    assert record.eventSourceARN == raw_record["eventSourceARN"]
    assert record.eventVersion == raw_record["eventVersion"]
    assert record.invokeIdentityArn == raw_record["invokeIdentityArn"]
    kinesis: KinesisDataStreamRecordPayload = record.kinesis
    assert kinesis.approximateArrivalTimestamp == raw_record["kinesis"]["approximateArrivalTimestamp"]
    assert kinesis.kinesisSchemaVersion == raw_record["kinesis"]["kinesisSchemaVersion"]
    assert kinesis.partitionKey == raw_record["kinesis"]["partitionKey"]
    assert kinesis.sequenceNumber == raw_record["kinesis"]["sequenceNumber"]
    assert kinesis.data == b"Hello, this is a test."