Skip to content

Commit 7ec47f1

Browse files
leandrodamascenaleandrodamascena
committed
Renaming namespace
1 parent 1c9606a commit 7ec47f1

24 files changed

Lines changed: 55 additions & 55 deletions

‎aws_lambda_powertools/utilities/kafka/__init__.py‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
from aws_lambda_powertools.utilities.kafka.consumer_records import ConsumerRecords
2+
from aws_lambda_powertools.utilities.kafka.kafka_consumer import kafka_consumer
3+
from aws_lambda_powertools.utilities.kafka.schema_config import SchemaConfig
4+
5+
__all__ = [
6+
"kafka_consumer",
7+
"ConsumerRecords",
8+
"SchemaConfig",
9+
]

aws_lambda_powertools/utilities/kafka_consumer/consumer_records.py renamed to aws_lambda_powertools/utilities/kafka/consumer_records.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,13 +5,13 @@
55

66
from aws_lambda_powertools.utilities.data_classes.common import CaseInsensitiveDict, DictWrapper
77
from aws_lambda_powertools.utilities.data_classes.kafka_event import KafkaEventBase, KafkaEventRecordBase
8-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.deserializer import get_deserializer
9-
from aws_lambda_powertools.utilities.kafka_consumer.serialization.serialization import serialize_to_output_type
8+
from aws_lambda_powertools.utilities.kafka.deserializer.deserializer import get_deserializer
9+
from aws_lambda_powertools.utilities.kafka.serialization.serialization import serialize_to_output_type
1010

1111
if TYPE_CHECKING:
1212
from collections.abc import Iterator
1313

14-
from aws_lambda_powertools.utilities.kafka_consumer.schema_config import SchemaConfig
14+
from aws_lambda_powertools.utilities.kafka.schema_config import SchemaConfig
1515

1616

1717
class ConsumerRecordSchemaMetadata(DictWrapper):

aws_lambda_powertools/utilities/kafka_consumer/deserializer/__init__.py renamed to aws_lambda_powertools/utilities/kafka/deserializer/__init__.py

File renamed without changes.

aws_lambda_powertools/utilities/kafka_consumer/deserializer/avro.py renamed to aws_lambda_powertools/utilities/kafka/deserializer/avro.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@
55
from avro.io import BinaryDecoder, DatumReader
66
from avro.schema import parse as parse_schema
77

8-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.base import DeserializerBase
9-
from aws_lambda_powertools.utilities.kafka_consumer.exceptions import (
8+
from aws_lambda_powertools.utilities.kafka.deserializer.base import DeserializerBase
9+
from aws_lambda_powertools.utilities.kafka.exceptions import (
1010
KafkaConsumerAvroSchemaParserError,
1111
KafkaConsumerDeserializationError,
1212
)

aws_lambda_powertools/utilities/kafka_consumer/deserializer/base.py renamed to aws_lambda_powertools/utilities/kafka/deserializer/base.py

File renamed without changes.

aws_lambda_powertools/utilities/kafka_consumer/deserializer/default.py renamed to aws_lambda_powertools/utilities/kafka/deserializer/default.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import base64
44

5-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.base import DeserializerBase
5+
from aws_lambda_powertools.utilities.kafka.deserializer.base import DeserializerBase
66

77

88
class DefaultDeserializer(DeserializerBase):

aws_lambda_powertools/utilities/kafka_consumer/deserializer/deserializer.py renamed to aws_lambda_powertools/utilities/kafka/deserializer/deserializer.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3,11 +3,11 @@
33
import hashlib
44
from typing import TYPE_CHECKING, Any
55

6-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.default import DefaultDeserializer
7-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.json import JsonDeserializer
6+
from aws_lambda_powertools.utilities.kafka.deserializer.default import DefaultDeserializer
7+
from aws_lambda_powertools.utilities.kafka.deserializer.json import JsonDeserializer
88

99
if TYPE_CHECKING:
10-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.base import DeserializerBase
10+
from aws_lambda_powertools.utilities.kafka.deserializer.base import DeserializerBase
1111

1212
# Cache for deserializers
1313
_deserializer_cache: dict[str, DeserializerBase] = {}
@@ -85,12 +85,12 @@ def get_deserializer(schema_type: str | object, schema_value: Any) -> Deserializ
8585

8686
if schema_type == "AVRO":
8787
# Import here to avoid dependency if not used
88-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.avro import AvroDeserializer
88+
from aws_lambda_powertools.utilities.kafka.deserializer.avro import AvroDeserializer
8989

9090
deserializer = AvroDeserializer(schema_value)
9191
elif schema_type == "PROTOBUF":
9292
# Import here to avoid dependency if not used
93-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.protobuf import ProtobufDeserializer
93+
from aws_lambda_powertools.utilities.kafka.deserializer.protobuf import ProtobufDeserializer
9494

9595
deserializer = ProtobufDeserializer(schema_value)
9696
elif schema_type == "JSON":

aws_lambda_powertools/utilities/kafka_consumer/deserializer/json.py renamed to aws_lambda_powertools/utilities/kafka/deserializer/json.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@
33
import base64
44
import json
55

6-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.base import DeserializerBase
7-
from aws_lambda_powertools.utilities.kafka_consumer.exceptions import KafkaConsumerDeserializationError
6+
from aws_lambda_powertools.utilities.kafka.deserializer.base import DeserializerBase
7+
from aws_lambda_powertools.utilities.kafka.exceptions import KafkaConsumerDeserializationError
88

99

1010
class JsonDeserializer(DeserializerBase):

aws_lambda_powertools/utilities/kafka_consumer/deserializer/protobuf.py renamed to aws_lambda_powertools/utilities/kafka/deserializer/protobuf.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44

55
from google.protobuf.json_format import MessageToDict
66

7-
from aws_lambda_powertools.utilities.kafka_consumer.deserializer.base import DeserializerBase
8-
from aws_lambda_powertools.utilities.kafka_consumer.exceptions import (
7+
from aws_lambda_powertools.utilities.kafka.deserializer.base import DeserializerBase
8+
from aws_lambda_powertools.utilities.kafka.exceptions import (
99
KafkaConsumerDeserializationError,
1010
)
1111

aws_lambda_powertools/utilities/kafka_consumer/exceptions.py renamed to aws_lambda_powertools/utilities/kafka/exceptions.py

File renamed without changes.

0 commit comments

Comments
 (0)