faust.worker
¶
Worker.
A “worker” starts a single instance of a Faust application.
See also
Starting the App: for more information.
-
class
faust.worker.
Worker
(app: faust.types.app.AppT, *services, sensors: Iterable[faust.types.sensors.SensorT] = None, debug: bool = False, quiet: bool = False, loglevel: Union[str, int] = None, logfile: Union[str, typing.IO] = None, stdout: IO = <_io.TextIOWrapper name='<stdout>' mode='w' encoding='UTF-8'>, stderr: IO = <_io.TextIOWrapper name='<stderr>' mode='w' encoding='UTF-8'>, blocking_timeout: float = 10.0, workdir: Union[pathlib.Path, str] = None, Website: Union[typing.Type[faust.web.site.Website], str] = 'faust.web.site:Website', web_port: int = None, web_bind: str = None, web_host: str = None, console_port: int = 50101, loop: asyncio.events.AbstractEventLoop = None, **kwargs) → None[source]¶ Worker.
- Usage:
You can start a worker using:
the faust worker program.
instantiating Worker programmatically and calling execute_from_commandline():
>>> worker = Worker(app) >>> worker.execute_from_commandline()
or if you already have an event loop, calling
await start
, but in that case you are responsible for gracefully shutting down the event loop:async def start_worker(worker: Worker) -> None: await worker.start() def manage_loop(): loop = asyncio.get_event_loop() worker = Worker(app, loop=loop) try: loop.run_until_complete(start_worker(worker) finally: worker.stop_and_shutdown_loop()
Parameters: - app (
AppT
[]) – The Faust app to start. - *services – Services to start with worker. This includes application instances to start.
- sensors (Iterable[SensorT]) – List of sensors to include.
- debug (bool) – Enables debugging mode [disabled by default].
- quiet (bool) – Do not output anything to console [disabled by default].
- loglevel (Union[str, int]) – Level to use for logging, can be string (one of: CRIT|ERROR|WARN|INFO|DEBUG), or integer.
- logfile (Union[str, IO]) – Name of file or a stream to log to.
- stdout (IO) – Standard out stream.
- stderr (IO) – Standard err stream.
- blocking_timeout (float) – When
debug
is enabled this sets the timeout for detecting that the event loop is blocked. - workdir (Union[str, Path]) – Custom working directory for the process that the worker will change into when started. This working directory change is permanent for the process, or until something else changes the working directory again.
- Website (
Union
[Type
[Website
[]]]) – Class used to serve the Faust web site (defaults tofaust.web.site.Website
). - web_port (int) – Port for web site to bind to (defaults to 6066).
- web_bind (str) – Host to bind web site to (defaults to “0.0.0.0”).
- web_host (str) – Canonical host name used for this server. (defaults to the current host name).
- loop (asyncio.AbstractEventLoop) – Custom event loop object.
-
logger
= <Logger faust.worker (WARNING)>¶
-
app
= None¶ The Faust app started by this worker.
-
sensors
= None¶ Additional sensors to add to the Faust app.
-
workdir
= None¶ Current working directory. Note that if passed as an argument to Worker, the worker will change to this directory when started.
-
Website
= None¶ Class that starts our web server and serves the Faust website.
-
web_port
= None¶ Port to run the embedded web server on (defaults to 6066).
-
web_bind
= None¶ Host to bind web server port to (defaults to ‘0.0.0.0’).
-
on_init_dependencies
() → Iterable[mode.types.services.ServiceT][source]¶ Callback to be used to add service dependencies.
Return type: Iterable
[ServiceT
[]]