faust.types.settings

class faust.types.settings.Settings(id: str, *, version: int = None, broker: Union[str, yarl.URL] = None, broker_client_id: str = None, broker_commit_every: int = None, broker_commit_interval: Union[datetime.timedelta, float, str] = None, broker_commit_livelock_soft_timeout: Union[datetime.timedelta, float, str] = None, broker_session_timeout: Union[datetime.timedelta, float, str] = None, broker_heartbeat_interval: Union[datetime.timedelta, float, str] = None, broker_check_crcs: bool = None, agent_supervisor: Union[typing.Type[mode.types.supervisors.SupervisorStrategyT], str] = None, store: Union[str, yarl.URL] = None, autodiscover: Union[bool, typing.Iterable[str], typing.Callable[[], typing.Iterable[str]]] = None, origin: str = None, canonical_url: Union[str, yarl.URL] = None, datadir: Union[pathlib.Path, str] = None, tabledir: Union[pathlib.Path, str] = None, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, loghandlers: List[logging.StreamHandler] = None, table_cleanup_interval: Union[datetime.timedelta, float, str] = None, table_standby_replicas: int = None, topic_replication_factor: int = None, topic_partitions: int = None, id_format: str = None, reply_to: str = None, reply_to_prefix: str = None, reply_create_topic: bool = None, reply_expires: Union[datetime.timedelta, float, str] = None, stream_buffer_maxsize: int = None, stream_wait_empty: bool = None, stream_ack_cancelled_tasks: bool = None, stream_ack_exceptions: bool = None, stream_publish_on_commit: bool = None, producer_linger_ms: int = None, producer_max_batch_size: int = None, producer_acks: int = None, producer_max_request_size: int = None, producer_compression_type: str = None, worker_redirect_stdouts: bool = None, worker_redirect_stdouts_level: Union[int, str] = None, Agent: Union[typing.Type[faust.types.agents.AgentT], str] = None, Stream: Union[typing.Type[faust.types.streams.StreamT], str] = None, Table: Union[typing.Type[faust.types.tables.TableT], str] = None, TableManager: Union[typing.Type[faust.types.tables.TableManagerT], str] = None, Serializers: Union[typing.Type[faust.types.serializers.RegistryT], str] = None, Worker: Union[typing.Type[faust.types.settings.WorkerT], str] = None, PartitionAssignor: Union[typing.Type[faust.types.assignor.PartitionAssignorT], str] = None, LeaderAssignor: Union[typing.Type[faust.types.assignor.LeaderAssignorT], str] = None, Router: Union[typing.Type[faust.types.router.RouterT], str] = None, Topic: Union[typing.Type[faust.types.topics.TopicT], str] = None, HttpClient: Union[typing.Type[faust.types.web.HttpClientT], str] = None, Monitor: Union[typing.Type[faust.types.sensors.SensorT], str] = None, url: Union[str, yarl.URL] = None, **kwargs) → None[source]
classmethod setting_names() → Set[str][source]
Return type:Set[str]
id_format = '{id}-v{self.version}'
origin = None
autodiscover = False
broker_client_id = 'faust-1.0.30'
broker_commit_every = 10000
broker_check_crcs = True
key_serializer = 'json'
value_serializer = 'json'
table_standby_replicas = 1
topic_replication_factor = 1
topic_partitions = 8
reply_create_topic = False
stream_buffer_maxsize = 4096
stream_wait_empty = False
stream_ack_cancelled_tasks = False
stream_ack_exceptions = True
stream_publish_on_commit = True
producer_linger_ms = 0
producer_max_batch_size = 16384
producer_acks = -1
producer_max_request_size = 1000000
producer_compression_type = None
worker_redirect_stdouts = True
worker_redirect_stdouts_level = 'WARN'
reply_to_prefix = 'f-reply-'
prepare_id(id: str) → str[source]
Return type:str
prepare_datadir(datadir: Union[str, pathlib.Path]) → pathlib.Path[source]
Return type:Path
prepare_tabledir(tabledir: Union[str, pathlib.Path]) → pathlib.Path[source]
Return type:Path
name
id
version
broker
store
canonical_url
datadir
appdir
tabledir
broker_session_timeout
broker_heartbeat_interval
broker_commit_interval
broker_commit_livelock_soft_timeout
table_cleanup_interval
reply_expires
agent_supervisor
Agent
Stream
Table
TableManager
Serializers
Worker
PartitionAssignor
LeaderAssignor
Router
Topic
HttpClient
Monitor