1
1
from typing import List
2
2
3
3
from aws_lambda_powertools .utilities .parser import envelopes , event_parser
4
- from aws_lambda_powertools .utilities .parser .models import KafkaEventModel , KafkaRecordModel , MskEventModel
4
+ from aws_lambda_powertools .utilities .parser .models import (
5
+ KafkaMskEventModel ,
6
+ KafkaRecordModel ,
7
+ KafkaSelfManagedEventModel ,
8
+ )
5
9
from aws_lambda_powertools .utilities .typing import LambdaContext
6
10
from tests .functional .parser .schemas import MyLambdaKafkaBusiness
7
11
from tests .functional .utils import load_event
@@ -13,19 +17,19 @@ def handle_lambda_kafka_with_envelope(event: List[MyLambdaKafkaBusiness], _: Lam
13
17
assert len (event ) == 1
14
18
15
19
16
- @event_parser (model = KafkaEventModel )
17
- def handle_kafka_event (event : KafkaEventModel , _ : LambdaContext ):
20
+ @event_parser (model = KafkaSelfManagedEventModel )
21
+ def handle_kafka_event (event : KafkaSelfManagedEventModel , _ : LambdaContext ):
18
22
return event
19
23
20
24
21
25
def test_kafka_event_with_envelope ():
22
- event = load_event ("kafkaEventSelfManaged .json" )
26
+ event = load_event ("kafkaEventMsk .json" )
23
27
handle_lambda_kafka_with_envelope (event , LambdaContext ())
24
28
25
29
26
30
def test_self_managed_kafka_event ():
27
31
json_event = load_event ("kafkaEventSelfManaged.json" )
28
- event : KafkaEventModel = handle_kafka_event (json_event , LambdaContext ())
32
+ event : KafkaSelfManagedEventModel = handle_kafka_event (json_event , LambdaContext ())
29
33
assert event .eventSource == "aws:SelfManagedKafka"
30
34
bootstrap_servers = [
31
35
"b-2.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092" ,
@@ -49,14 +53,14 @@ def test_self_managed_kafka_event():
49
53
assert record .headers [0 ]["headerKey" ] == b"headerValue"
50
54
51
55
52
- @event_parser (model = MskEventModel )
53
- def handle_msk_event (event : MskEventModel , _ : LambdaContext ):
56
+ @event_parser (model = KafkaMskEventModel )
57
+ def handle_msk_event (event : KafkaMskEventModel , _ : LambdaContext ):
54
58
return event
55
59
56
60
57
61
def test_kafka_msk_event ():
58
62
json_event = load_event ("kafkaEventMsk.json" )
59
- event : MskEventModel = handle_msk_event (json_event , LambdaContext ())
63
+ event : KafkaMskEventModel = handle_msk_event (json_event , LambdaContext ())
60
64
assert event .eventSource == "aws:kafka"
61
65
bootstrap_servers = [
62
66
"b-2.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092" ,
0 commit comments