whylogs_container.whylabs.logger.logger

Functions

create_logger(config_instance)

Classes

ContainerLoggerFactory(config_instance)
ContainerProcessRollingLogger(aggregate_by, ...)
LogV1Client([org_id, api_key, dataset_id, ...])
MultiOrgWriterFactory()

class whylogs_container.whylabs.logger.logger.ContainerLoggerFactory(config_instance: ConfigInstance)

Bases: ThreadLoggerFactory

create_logger(dataset_id: str, org_id: str | None, options: LoggerOptions) → ThreadRollingLogger

class whylogs_container.whylabs.logger.logger.ContainerProcessRollingLogger(aggregate_by: ~whylogs.api.logger.experimental.logger.actor.time_util.TimeGranularity = TimeGranularity.Day, write_schedule: ~whylogs.api.logger.experimental.logger.actor.time_util.Schedule | None = Schedule(cadence=<TimeGranularity.Minute: 'Minute'>, interval=5), schema: ~whylogs.core.schema.DatasetSchema | None = None, sync_enabled: bool = False, current_time_fn: ~typing.Callable[[], int] | None = None, queue_config: ~whylogs.api.logger.experimental.logger.actor.actor.QueueConfig = QueueConfig(max_batch_size=50000, message_accumualtion_duration=1.0, message_poll_wait=0.1, max_buffer_bytes=100000000), thread_queue_config: ~whylogs.api.logger.experimental.logger.actor.actor.QueueConfig = QueueConfig(max_batch_size=50000, message_accumualtion_duration=1.0, message_poll_wait=0.1, max_buffer_bytes=100000000), writer_factory: ~whylogs.api.logger.experimental.logger.actor.process_rolling_logger.WriterFactory = <whylogs.api.logger.experimental.logger.actor.process_rolling_logger.WhyLabsWriterFactory object>, queue_type: ~whylogs.api.logger.experimental.logger.actor.process_actor.QueueType = QueueType.FASTER_FIFO, logger_factory: ~whylogs.api.logger.experimental.logger.actor.process_rolling_logger.LoggerFactory = <whylogs.api.logger.experimental.logger.actor.process_rolling_logger.ThreadLoggerFactory object>)

Bases: ProcessRollingLogger

is_closed() → bool

class whylogs_container.whylabs.logger.logger.LogV1Client(org_id: str | None = None, api_key: str | None = None, dataset_id: str | None = None, api_client: ApiClient | None = None, ssl_ca_cert: str | None = None, _timeout_seconds: float | None = None)

Bases: WhyLabsClient

class whylogs_container.whylabs.logger.logger.MultiOrgWriterFactory

Bases: WriterFactory

create_writers(dataset_id: str, org_id: str | None = None) → List[Writer]

whylogs_container.whylabs.logger.logger.create_logger(config_instance: ConfigInstance) → ContainerProcessRollingLogger