​
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