ConnectorTypeREDIS

class connector_types.connector_type_redis.ConnectorTypeREDIS

Interact with a REDIS key value store.

warning

This connector type currently only supports unencrypted and unauthenticated connections to REDIS. Contact info@cloudomation.com to request a feature.

Consult the redis commands documentation at https://redis.io/commands for details on commands, arguments and result schemas.

Inputs

Name	Type	Default	Description
args	list	[]
command	str
host	str
port	int	6379

Outputs

Name	Type	Default	Description
execution_id	int		The ID of the connection execution
message	str		The ended message for the connection. If the connection ended with an error, the message will contain information about what went wrong
result	object
status	str		The ended status for the connection. Either "success" or "error".

Constants

input_list = ['args', 'command', 'host', 'port'] output_list = ['result'] ssl_context_inputs = ['check_hostname', 'client_cert', 'client_key', 'server_ca'] version = 1

Methods

execute ()

log (message)

one_of_inputs (options)

run ()

Example

import flow_api
def handler(system: flow_api.System, this: flow_api.Execution):
    redis_server_info = this.connect(
        connector_type='REDIS',
        host='my-redis-host',
        command='INFO',
    ).get('output_value')['result']
    this.log(redis_server_info=redis_server_info)
    return this.success('all done')