prefect.blocks.redis

Classes

RedisStorageContainer

Block used to interact with Redis as a filesystem Methods:

block_initialization

block_initialization(self) -> None

from_connection_string

from_connection_string(cls, connection_string: str | SecretStr) -> Self
Create block from a Redis connection string Supports the following URL schemes:
  • redis:// creates a TCP socket connection
  • rediss:// creates a SSL wrapped TCP socket connection
  • unix:// creates a Unix Domain Socket connection
See [Redis docs](https://redis.readthedocs.io/en/stable/examples /connection_examples.html#Connecting-to-Redis-instances-by-specifying-a-URL -scheme.) for more info. Args:
  • connection_string: Redis connection string
Returns:
  • RedisStorageContainer instance

from_host

from_host(cls, host: str, port: int = 6379, db: int = 0, username: None | str | SecretStr = None, password: None | str | SecretStr = None) -> Self
Create block from hostname, username and password Args:
  • host: Redis hostname
  • username: Redis username
  • password: Redis password
  • port: Redis port
Returns:
  • RedisStorageContainer instance

read_path

read_path(self, path: Path | str)
Read the redis content at path Args:
  • path: Redis key to read from
Returns:
  • Contents at key as bytes

read_path

read_path(self, path: str) -> bytes

write_path

write_path(self, path: Path | str, content: bytes)
Write content to the redis at path Args:
  • path: Redis key to write to
  • content: Binary object to write

write_path

write_path(self, path: str, content: bytes) -> None