prefect.logging.clients

Functions

http_to_ws

http_to_ws(url: str) -> str

logs_out_socket_from_api_url

logs_out_socket_from_api_url(url: str) -> str

get_logs_subscriber

get_logs_subscriber(filter: Optional['LogFilter'] = None, reconnection_attempts: int = 10) -> 'PrefectLogsSubscriber'
Get a logs subscriber based on the current Prefect configuration. Similar to get_events_subscriber, this automatically detects whether you’re using Prefect Cloud or OSS and returns the appropriate subscriber.

Classes

PrefectLogsSubscriber

Subscribes to a Prefect logs stream, yielding logs as they occur. Example: from prefect.logging.clients import PrefectLogsSubscriber from prefect.client.schemas.filters import LogFilter, LogFilterLevel import logging filter = LogFilter(level=LogFilterLevel(ge_=logging.INFO)) async with PrefectLogsSubscriber(filter=filter) as subscriber: async for log in subscriber: print(log.timestamp, log.level, log.message) Methods:

client_name

client_name(self) -> str

PrefectCloudLogsSubscriber

Logs subscriber for Prefect Cloud Methods:

client_name

client_name(self) -> str