Skip to main content

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

NameTypeDefaultDescription
argslist[]
commandstr
hoststr
portint6379

Outputs

NameTypeDefaultDescription
execution_idintThe ID of the connection execution
messagestrThe ended message for the connection. If the connection ended with an error, the message will contain information about what went wrong
resultobject
statusstrThe ended status for the connection. Either "success" or "error".

Constants

input_list = ['args', 'command', 'host', 'port']output_list = ['result']version = 1

Methods

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')