The fluvio cloud connector
subcommands are used to manage Connectors in InfinyOn Cloud.
$ fluvio cloud connector -h
fluvio-cloud-connector
View Fluvio Connector information
USAGE:
fluvio-cloud connector <SUBCOMMAND>
OPTIONS:
-h, --help Print help information
SUBCOMMANDS:
config Show the connector configuration details
create Create a new Connector
delete Delete a Connector
help Print this message or the help of the given subcommand(s)
list List all Connectors
logs View connector logs
update Update and restart a Connector
This command is used to provision a new connector.
$ fluvio cloud connector create -h
fluvio-cloud-connector-create
Create a new Connector
USAGE:
fluvio-cloud connector create --config <CONFIG>
OPTIONS:
-c, --config <CONFIG> Name of connector
-h, --help Print help information
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 or the connector template
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
fluvio-cloud-connector-config
Show the connector configuration details
USAGE:
fluvio-cloud connector config <NAME>
ARGS:
<NAME> Name of connector
OPTIONS:
-h, --help Print help information
Example usage:
$ fluvio cloud connector config cat-facts
name: cat-facts
type: http-source
topic: cat-facts
version: 0.4.2
parameters:
endpoint: https://catfact.ninja/fact
interval: 10s
This command show you all the existing Connectors in your cluster.
$ fluvio cloud connector list -h
fluvio-cloud-connector-list
List all Connectors
USAGE:
fluvio-cloud connector list
OPTIONS:
-h, --help Print help information
Command to update and restart an existing connector.
$ fluvio cloud connector update -h
fluvio-cloud-connector-update
Update and restart a Connector
USAGE:
fluvio-cloud connector update --config <CONFIG>
OPTIONS:
-c, --config <CONFIG> Name of connector
-h, --help Print help information
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
fluvio-cloud-connector-logs
View connector logs
USAGE:
fluvio-cloud connector logs <NAME>
ARGS:
<NAME> Name of connector
OPTIONS:
-h, --help Print help information
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
...
This command deletes an existing Connector.
$ fluvio cloud connector delete -h
fluvio-cloud-connector-delete
Delete a Connector
USAGE:
fluvio-cloud connector delete <name>...
ARGS:
<name>... One or more name(s) of the connector(s) to be deleted
OPTIONS:
-h, --help Print help information
Example usage:
$ fluvio cloud connector delete cat-facts
connector "cat-facts" deleted