faust.cli.faust

Program faust (umbrella command).

class faust.cli.faust.agents(ctx: click.core.Context, *args, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, **kwargs) → None

List agents.

title = 'Agents'

headers = ['name', 'topic', 'help']

sortkey = operator.attrgetter('name')

options = [<function option.<locals>.decorator>]

agents(*, local: bool = False) → Sequence[faust.types.agents.AgentT]

Return type:Sequence[AgentT[]]

agent_to_row(agent: faust.types.agents.AgentT) → Sequence[str]

Return type:Sequence[str]

coroutine run(self, local: bool) → None

Return type:None

class faust.cli.faust.completion(ctx: click.core.Context, *args, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, **kwargs) → None

Output shell completion to be eval’d by the shell.

require_app = False

shell() → str

Return type:str

coroutine run(self) → None

Return type:None

class faust.cli.faust.model(ctx: click.core.Context, *args, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, **kwargs) → None

Show model detail.

headers = ['field', 'type', 'default*']

options = [<function argument.<locals>.decorator>]

model_fields(model: Type[faust.types.models.ModelT]) → Sequence[Sequence[str]]

Return type:Sequence[Sequence[str]]

field(field: faust.types.models.FieldDescriptorT) → Sequence[str]

Return type:Sequence[str]

model_to_row(model: Type[faust.types.models.ModelT]) → Sequence[str]

Return type:Sequence[str]

coroutine run(self, name: str) → None

Return type:None

class faust.cli.faust.models(ctx: click.core.Context, *args, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, **kwargs) → None

List all available models as a tabulated list.

title = 'Models'

headers = ['name', 'help']

sortkey = operator.attrgetter('_options.namespace')

options = [<function option.<locals>.decorator>]

models(builtins: bool) → Sequence[Type[faust.types.models.ModelT]]

Return type:Sequence[Type[ModelT]]

model_to_row(model: Type[faust.types.models.ModelT]) → Sequence[str]

Return type:Sequence[str]

coroutine run(self, *, builtins: bool) → None

Return type:None

class faust.cli.faust.reset(ctx: click.core.Context, *args, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, **kwargs) → None

Delete local table state.

Warning

This command will result in the destruction of the following files:

1. The local database directories/files backing tables (does not apply if an in-memory store like memory:// is used).

Notes

This data is technically recoverable from the Kafka cluster (if intact), but it’ll take a long time to get the data back as you need to consume each changelog topic in total.

It’d be faster to copy the data from any standbys that happen to have the topic partitions you require.

coroutine reset_tables(self) → None

Return type:None

coroutine run(self) → None

Return type:None

class faust.cli.faust.send(ctx: click.core.Context, *args, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, **kwargs) → None

Send message to agent/topic.

options = [<function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function argument.<locals>.decorator>, <function argument.<locals>.decorator>]

coroutine run(self, entity: str, value: str, *args, key: str = None, key_type: str = None, key_serializer: str = None, value_type: str = None, value_serializer: str = None, partition: int = 1, repeat: int = 1, min_latency: float = 0.0, max_latency: float = 0.0, **kwargs) → Any

Return type:Any

class faust.cli.faust.tables(ctx: click.core.Context, *args, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, **kwargs) → None

List available tables.

title = 'Tables'

coroutine run(self) → None

Return type:None

class faust.cli.faust.worker(ctx: click.core.Context, *args, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, **kwargs) → None

Start ƒaust worker instance.

options = [<function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>, <function option.<locals>.decorator>]

start_worker(logfile: str, loglevel: str, blocking_timeout: float, web_port: int, web_bind: str, web_host: str, console_port: int) → Any

Return type:Any

banner(worker: faust.cli.worker.Worker) → str

Generate the text banner emitted before the worker starts.

Return type:str

faust_ident() → str

Return type:str

platform() → str

Return type:str