A Python CLI to interact with the Fluentd HTTP RPC API.

From PyPi:

pip install fluentdctl

From source:

python setup.py

The fluentd RPC endpoint must be enabled in your fluentd endpoint.

If you wish to manage a fluentd instance running on another machine, the binding in the configuration cannot be to 127.0.0.1. It must either be 0.0.0.0 (all addresses) or a specific IP of the machine. Example:

<system>
  rpc_endpoint 0.0.0.0:24444
</system>

To flush the fluentd buffer:

fluentdctl flush

To stop the fluentd process:

fluentdctl stop

To flush and then stop the fluentd process:

fluentdctl flushthenstop

To reload the fluentd process and configuration:

fluentdctl reload

The commands above will run against a local instance of fluentd running on the default port of 24444.

However with each command you can optionally specify a different remote host and/or port:

fluentdctl flush --host remote-srv-01 --port 12345

OR specify them positionally

fluentdctl flush remote-srv-01 12345

Finally you can also specify --verbose on any command to get additional output.