The fluvio cloud connector
subcommands are used to manage Connectors in InfinyOn Cloud.
$ fluvio cloud connector -h
View Fluvio Connector information
Usage: fluvio-cloud connector <COMMAND>
Commands:
logs View connector logs
create Create a new Connector
delete Delete a Connector
list List all Connectors
update Update and restart a Connector
config Show the connector configuration details
help Print this message or the help of the given subcommand(s)
Options:
-h, --help Print help
This command is used to provision a new connector.
$ fluvio cloud connector create -h
Create a new Connector
Usage: fluvio-cloud connector create [OPTIONS] --config <CONFIG>
Options:
-c, --config <CONFIG> Connector config
--log-level <LOG_LEVEL> Sets the log level [default: LogLevel::default()]
-h, --help Print help
To create a connector, you need to create a YAML-based connector config file.
For more about the connector config file, see the Cloud connectors page.
When running fluvio cloud connector create
, pass the path to this file using the --config
option.
Example usage:
$ fluvio cloud connector create --config=./cats.yaml
connector "cat-facts" (http-source) created
Command to show the configuration file used to create this connector.
$ fluvio cloud connector config -h
Show the connector configuration details
Usage: fluvio-cloud connector config <NAME>
Arguments:
<NAME> Name of connector
Options:
-h, --help Print help
Example usage:
apiVersion: 0.1.0
meta:
version: 0.2.1
name: cat-facts
type: http-source
topic: cat-facts
create-topic: true
http:
endpoint: "https://catfact.ninja/fact"
interval: 10s
This command show you all the existing Connectors in your cluster.
$ fluvio cloud connector list -h
List all Connectors
Usage: fluvio-cloud connector list
Options:
-h, --help Print help
Command to update and restart an existing connector.
$ fluvio cloud connector update -h
Update and restart a Connector
Usage: fluvio-cloud connector update [OPTIONS] --config <CONFIG>
Options:
-c, --config <CONFIG> Name of connector
--log-level <LOG_LEVEL> Sets the log level [default: LogLevel::default()]
-h, --help Print help
Example usage:
$ fluvio cloud connector update --config=./cats.yaml
connector "cat-facts" (http-source) updated
Command to view the logs written by the connector.
$ fluvio cloud connector logs -h
View connector logs
Usage: fluvio-cloud connector logs <NAME>
Arguments:
<NAME> Name of connector
Options:
-h, --help Print help
Example usage:
% fluvio cloud connector logs cat-facts
2022-10-21T14:55:13.508989Z INFO http_source: Starting HTTP source connector connector_version="0.4.1" git_hash="0ad913c5ceb732881fd753874e5082777bbed91e"
2022-10-21T14:55:13.509096Z INFO http_source: interval=10s method=GET topic=cat-facts output_parts=body output_type=text endpoint=https://catfact.ninja/fact
2022-10-21T14:55:13.510284Z INFO fluvio::config::tls: Using verified TLS with certificates from paths domain="broad-union-b685e7fda03fefb3d5221d0a3b9c64c7.c.infinyon.cloud"
2022-10-21T14:55:13.515459Z INFO fluvio::fluvio: Connecting to Fluvio cluster fluvio_crate_version="0.14.0" fluvio_git_hash="e96d8e2738ee39ddbb64fea37134f119f97e25bf"
2022-10-21T14:55:13.574584Z INFO connect: fluvio::sockets: connect to socket add=fluvio-sc-public:9003
...
By default connectors will log using the info
level.
You can configure the log level for connectors running in the cloud using
the --log-level
option.
The --log-level
option is available for both, fluvio cloud connector <create | update>
.
Any of the following levels can be used:
error
warn
info
debug
trace
This command deletes an existing Connector.
$ fluvio cloud connector delete -h
Delete a Connector
Usage: fluvio-cloud connector delete <name>...
Arguments:
<name>... One or more name(s) of the connector(s) to be deleted
Options:
-h, --help Print help
Example usage:
$ fluvio cloud connector delete cat-facts
connector "cat-facts" deleted