Contents Menu Expand Light mode Dark mode Auto light/dark, in light mode Auto light/dark, in dark mode Skip to content
python-web-toolkit documentation
python-web-toolkit documentation

Getting started

  • Quickstart
  • Architecture

Packages

  • Packages
    • python-technical-primitives
    • python-app-exceptions
    • python-infrastructure-exceptions
    • python-input-validation
    • postgres-data-sanitizers
    • pydantic-response-models
    • python-cqrs-core
    • Usage Guide
    • API Reference
    • Observability Integration
    • Why Use BaseQuery/BaseCommand?
    • gridflow-python-mediator
    • python-cqrs-dispatcher
    • python-dto-mappers
    • python-domain-events
    • python-structlog-config
    • fastapi-config-patterns
    • fastapi-middleware-toolkit
    • python-outbox-core
    • Outbox Core - Quick Reference
    • Outbox Core - API Quick Reference
    • Transactional Outbox Implementation Guide
    • Do we even need python-outbox-core if we use FastStream? Maybe FastStream by ag2ai itself replacing it? Or maybe Celery/Huey by coleifer. Grep codebase and Search web
    • Serialization Notes
    • sqlalchemy-async-session-factory
    • sqlalchemy-async-repositories
    • Architecture: Design Patterns & Interactions

Comparisons

  • Exception Libraries Comparison

API reference

  • API Reference
    • python_cqrs_core
      • python_cqrs_core.base_command
      • python_cqrs_core.base_query
      • python_cqrs_core.command
      • python_cqrs_core.query
    • python_dto_mappers
      • python_dto_mappers.auto_mapper
      • python_dto_mappers.base
      • python_dto_mappers.decorators
      • python_dto_mappers.field_mappers
        • python_dto_mappers.field_mappers.datetime_mapping
        • python_dto_mappers.field_mappers.object_mapping
        • python_dto_mappers.field_mappers.text_case
      • python_dto_mappers.utils
    • python_outbox_core
      • python_outbox_core.adapters
        • python_outbox_core.adapters.examples
          • python_outbox_core.adapters.examples.kafka_routing
          • python_outbox_core.adapters.examples.kong_simple
      • python_outbox_core.config
      • python_outbox_core.events
      • python_outbox_core.formatters
        • python_outbox_core.formatters.base
        • python_outbox_core.formatters.cloudevents
      • python_outbox_core.health_check
      • python_outbox_core.publisher
        • python_outbox_core.publisher.base
        • python_outbox_core.publisher.error_handler
        • python_outbox_core.publisher.interface
        • python_outbox_core.publisher.metrics
      • python_outbox_core.repository
    • python_domain_events
      • python_domain_events.base
      • python_domain_events.dispatcher
      • python_domain_events.handler
    • python_app_exceptions
      • python_app_exceptions.base
      • python_app_exceptions.business
      • python_app_exceptions.retry
      • python_app_exceptions.validation
    • python_cqrs_dispatcher
      • python_cqrs_dispatcher.dispatcher
      • python_cqrs_dispatcher.registry
    • python_input_validation
      • python_input_validation.sanitizers
      • python_input_validation.validators
    • python_structlog_config
      • python_structlog_config.config
      • python_structlog_config.integrations
      • python_structlog_config.presets
    • fastapi_config_patterns
      • fastapi_config_patterns.base_settings
      • fastapi_config_patterns.database_settings
      • fastapi_config_patterns.validators
    • postgres_data_sanitizers
      • postgres_data_sanitizers.escape
      • postgres_data_sanitizers.sanitize
      • postgres_data_sanitizers.string_validators
      • postgres_data_sanitizers.validate
    • pydantic_response_models
      • pydantic_response_models.fields
      • pydantic_response_models.responses
    • gridflow_python_mediator
      • gridflow_python_mediator.behaviors
        • gridflow_python_mediator.behaviors.observability
        • gridflow_python_mediator.behaviors.protocol
        • gridflow_python_mediator.behaviors.validation_behavior
      • gridflow_python_mediator.mediator
    • fastapi_middleware_toolkit
      • fastapi_middleware_toolkit.cache_control
      • fastapi_middleware_toolkit.cors
      • fastapi_middleware_toolkit.error_handlers
      • fastapi_middleware_toolkit.lifespan
    • python_technical_primitives
      • python_technical_primitives.datetime
        • python_technical_primitives.datetime.operations
      • python_technical_primitives.patterns
        • python_technical_primitives.patterns.base
        • python_technical_primitives.patterns.compositions
      • python_technical_primitives.text
        • python_technical_primitives.text.operations
    • sqlalchemy_async_repositories
      • sqlalchemy_async_repositories.base
      • sqlalchemy_async_repositories.interfaces
      • sqlalchemy_async_repositories.pagination
        • sqlalchemy_async_repositories.pagination.models
        • sqlalchemy_async_repositories.pagination.router
        • sqlalchemy_async_repositories.pagination.strategies
          • sqlalchemy_async_repositories.pagination.strategies.base
          • sqlalchemy_async_repositories.pagination.strategies.fastcrud_strategy
          • sqlalchemy_async_repositories.pagination.strategies.native_strategy
      • sqlalchemy_async_repositories.pagination_fastcrud
      • sqlalchemy_async_repositories.pagination_native
      • sqlalchemy_async_repositories.use_cases
        • sqlalchemy_async_repositories.use_cases.count
          • sqlalchemy_async_repositories.use_cases.count.query_handler
          • sqlalchemy_async_repositories.use_cases.count.query_model
        • sqlalchemy_async_repositories.use_cases.create
          • sqlalchemy_async_repositories.use_cases.create.command_handler
          • sqlalchemy_async_repositories.use_cases.create.command_model
        • sqlalchemy_async_repositories.use_cases.delete
          • sqlalchemy_async_repositories.use_cases.delete.command_handler
          • sqlalchemy_async_repositories.use_cases.delete.command_model
        • sqlalchemy_async_repositories.use_cases.exists
          • sqlalchemy_async_repositories.use_cases.exists.query_handler
          • sqlalchemy_async_repositories.use_cases.exists.query_model
        • sqlalchemy_async_repositories.use_cases.find_paginated
          • sqlalchemy_async_repositories.use_cases.find_paginated.query_handler
          • sqlalchemy_async_repositories.use_cases.find_paginated.query_model
          • sqlalchemy_async_repositories.use_cases.find_paginated.strategy_factory
        • sqlalchemy_async_repositories.use_cases.get_all
          • sqlalchemy_async_repositories.use_cases.get_all.query_handler
          • sqlalchemy_async_repositories.use_cases.get_all.query_model
        • sqlalchemy_async_repositories.use_cases.get_by_id
          • sqlalchemy_async_repositories.use_cases.get_by_id.query_handler
          • sqlalchemy_async_repositories.use_cases.get_by_id.query_model
        • sqlalchemy_async_repositories.use_cases.update
          • sqlalchemy_async_repositories.use_cases.update.command_handler
          • sqlalchemy_async_repositories.use_cases.update.command_model
    • python_infrastructure_exceptions
      • python_infrastructure_exceptions.base
      • python_infrastructure_exceptions.cache
      • python_infrastructure_exceptions.configuration
      • python_infrastructure_exceptions.database
      • python_infrastructure_exceptions.external_services
      • python_infrastructure_exceptions.messaging
    • sqlalchemy_async_session_factory
      • sqlalchemy_async_session_factory.engine
      • sqlalchemy_async_session_factory.session
      • sqlalchemy_async_session_factory.utils
Back to top
View this page

python_outbox_core.formatters¶

Event formatters for different message broker formats.

Submodules¶

  • python_outbox_core.formatters.base
  • python_outbox_core.formatters.cloudevents
Next
python_outbox_core.formatters.base
Previous
python_outbox_core.events
Copyright © 2026, GridFlow
Made with Sphinx and @pradyunsg's Furo
On this page
  • python_outbox_core.formatters
    • Submodules