Back to Prefect

messaging

docs/v3/api-ref/python/prefect-server-logs-messaging.mdx

3.6.30.dev3890 B
Original Source

prefect.server.logs.messaging

Log messaging for streaming logs through the messaging system.

Functions

create_log_publisher <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/logs/messaging.py#L22" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
create_log_publisher() -> AsyncGenerator[messaging.Publisher, None]

Creates a publisher for sending logs to the messaging system.

Returns:

  • A messaging publisher configured for the "logs" topic

publish_logs <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/logs/messaging.py#L33" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
publish_logs(logs: list[Log]) -> None

Publishes logs to the messaging system.

Args:

  • logs: The logs to publish