feat: Optional msgspec serialization (#687)

Author: edgarrmondragon

pyproject.toml

@@ -33,6 +33,9 @@ dependencies = [
     "sshtunnel==0.4.0",
     "singer-sdk[faker,sql]~=0.50.0",
 ]
+optional-dependencies.msgspec = [
+    "msgspec>=0.19.0",
+]
 
 [project.urls]
 Homepage = "https://meltano.com"

tap_postgres/tap.py

@@ -29,6 +29,14 @@
 if TYPE_CHECKING:
     from collections.abc import Mapping, Sequence
 
+# Try to import MsgSpecWriter for better performance
+try:
+    from singer_sdk.contrib.msgspec import MsgSpecWriter
+
+    _MSGSPEC_AVAILABLE = True
+except ImportError:
+    _MSGSPEC_AVAILABLE = False
+
 
 REPLICATION_SLOT_PATTERN = "^(?!pg_)[A-Za-z0-9_]{1,63}$"
 
@@ -40,6 +48,10 @@ class TapPostgres(SQLTap):
     package_name = "meltanolabs-tap-postgres"
     default_stream_class = PostgresStream
 
+    # Use MsgSpecWriter if available for ~15-20% performance improvement
+    if _MSGSPEC_AVAILABLE:
+        message_writer_class = MsgSpecWriter
+
     def __init__(
         self,
         *args,