Public Member Functions | |
| def | __del__ |
| def | __enter__ |
| def | __exit__ |
| def | __init__ |
| def | execute |
| def | execute_command |
| def | immediate_execute_command |
| def | load_scripts |
| def | multi |
| def | parse_response |
| def | pipeline_execute_command |
| def | reset |
| def | script_load_for_pipeline |
| def | unwatch |
| def | watch |
Public Attributes | |
| command_stack | |
| connection | |
| connection_pool | |
| explicit_transaction | |
| response_callbacks | |
| scripts | |
| shard_hint | |
| transaction | |
| watching | |
Static Public Attributes | |
| tuple | UNWATCH_COMMANDS = set(('DISCARD', 'EXEC', 'UNWATCH')) |
Private Member Functions | |
| def | _execute_pipeline |
| def | _execute_transaction |
Pipelines provide a way to transmit multiple commands to the Redis server in one transmission. This is convenient for batch processing, such as saving all the values in a list to Redis. All commands executed within a pipeline are wrapped with MULTI and EXEC calls. This guarantees all commands executed in the pipeline will be executed atomically. Any command raising an exception does *not* halt the execution of subsequent commands in the pipeline. Instead, the exception is caught and its instance is placed into the response list returned by execute(). Code iterating over the response list should be able to deal with an instance of an exception as a potential value. In general, these will be ResponseError exceptions, such as those raised when issuing a command on a key of a different datatype.
| def redis.client.BasePipeline.__init__ | ( | self, | |
| connection_pool, | |||
| response_callbacks, | |||
| transaction, | |||
| shard_hint | |||
| ) |
| def redis.client.BasePipeline.__del__ | ( | self | ) |
| def redis.client.BasePipeline.__enter__ | ( | self | ) |
| def redis.client.BasePipeline.__exit__ | ( | self, | |
| exc_type, | |||
| exc_value, | |||
| traceback | |||
| ) |
| def redis.client.BasePipeline._execute_pipeline | ( | self, | |
| connection, | |||
| commands | |||
| ) | [private] |
| def redis.client.BasePipeline._execute_transaction | ( | self, | |
| connection, | |||
| commands | |||
| ) | [private] |
| def redis.client.BasePipeline.execute | ( | self | ) |
| def redis.client.BasePipeline.execute_command | ( | self, | |
| args, | |||
| kwargs | |||
| ) |
| def redis.client.BasePipeline.immediate_execute_command | ( | self, | |
| args, | |||
| options | |||
| ) |
| def redis.client.BasePipeline.load_scripts | ( | self | ) |
| def redis.client.BasePipeline.multi | ( | self | ) |
| def redis.client.BasePipeline.parse_response | ( | self, | |
| connection, | |||
| command_name, | |||
| options | |||
| ) |
| def redis.client.BasePipeline.pipeline_execute_command | ( | self, | |
| args, | |||
| options | |||
| ) |
Stage a command to be executed when execute() is next called
Returns the current Pipeline object back so commands can be
chained together, such as:
pipe = pipe.set('foo', 'bar').incr('baz').decr('bang')
At some other point, you can then run: pipe.execute(),
which will execute all commands queued in the pipe.
| def redis.client.BasePipeline.reset | ( | self | ) |
| def redis.client.BasePipeline.script_load_for_pipeline | ( | self, | |
| script | |||
| ) |
| def redis.client.BasePipeline.unwatch | ( | self | ) |
| def redis.client.BasePipeline.watch | ( | self, | |
| names | |||
| ) |
tuple redis::client.BasePipeline::UNWATCH_COMMANDS = set(('DISCARD', 'EXEC', 'UNWATCH')) [static] |