基類：airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook
與 Amazon ElastiCache 互動。
提供圍繞 boto3.client("elasticache") 的厚封裝。
- 引數：
max_retries (int) – 檢查複製組可用性和刪除複製組的最大重試次數。如果未提供，則預設為 10
exponential_back_off_factor (float) – 決定下一次休眠時間的乘法因子。如果未提供，則預設為 1
initial_poke_interval (float) – 初始休眠時間（秒）。如果未提供，則預設為 60 秒
可以指定其他引數（例如 aws_conn_id），這些引數會傳遞給底層的 AwsBaseHook。
-
TERMINAL_STATES[source]
-
max_retries = 10[source]
-
exponential_back_off_factor = 1[source]
-
initial_poke_interval = 60[source]
-
create_replication_group(config)[source]
建立一個 Redis（停用叢集模式）或 Redis（啟用叢集模式）複製組。
- 引數：
config (dict) – 用於建立複製組的配置
- 返回：
來自 ElastiCache create replication group API 的響應
- 返回型別：
dict
-
delete_replication_group(replication_group_id)[source]
刪除現有複製組。
- 引數：
replication_group_id (str) – 要刪除的複製組的 ID
- 返回：
來自 ElastiCache delete replication group API 的響應
- 返回型別：
dict
-
describe_replication_group(replication_group_id)[source]
獲取有關特定複製組的資訊。
- 引數：
replication_group_id (str) – 要描述的複製組的 ID
- 返回：
來自 ElastiCache describe replication group API 的響應
- 返回型別：
dict
-
get_replication_group_status(replication_group_id)[source]
獲取複製組的當前狀態。
- 引數：
replication_group_id (str) – 要檢查狀態的複製組的 ID
- 返回：
複製組的當前狀態
- 返回型別：
str
-
is_replication_group_available(replication_group_id)[source]
檢查複製組是否可用。
- 引數：
replication_group_id (str) – 要檢查可用性的複製組的 ID
- 返回：
如果可用則為 True，否則為 False
- 返回型別：
bool
-
wait_for_availability(replication_group_id, initial_sleep_time=None, exponential_back_off_factor=None, max_retries=None)[source]
透過對其進行描述來檢查複製組是否可用。
- 引數：
replication_group_id (str) – 要檢查可用性的複製組的 ID
initial_sleep_time (float | None) – 初始休眠時間（秒）。如果未提供，則預設為類級別值
exponential_back_off_factor (float | None) – 決定下一次休眠時間的乘法因子。如果未提供，則預設為類級別值
max_retries (int | None) – 檢查複製組可用性的最大重試次數。如果未提供，則預設為類級別值
- 返回：
如果複製組可用則為 True，否則為 False
- 返回型別：
bool
-
wait_for_deletion(replication_group_id, initial_sleep_time=None, exponential_back_off_factor=None, max_retries=None)[source]
刪除複製組，確保其已被刪除或無法刪除。
- 引數：
replication_group_id (str) – 要刪除的複製組的 ID
initial_sleep_time (float | None) – 初始休眠時間（秒）。如果未提供，則預設為類級別值
exponential_back_off_factor (float | None) – 決定下一次休眠時間的乘法因子。如果未提供，則預設為類級別值
max_retries (int | None) – 檢查複製組可用性的最大重試次數。如果未提供，則預設為類級別值
- 返回：
來自 ElastiCache delete replication group API 的響應以及標識是否已刪除的標誌
-
ensure_delete_replication_group(replication_group_id, initial_sleep_time=None, exponential_back_off_factor=None, max_retries=None)[source]
刪除複製組，確保其已被刪除或無法刪除。
- 引數：
replication_group_id (str) – 要刪除的複製組的 ID
initial_sleep_time (float | None) – 初始休眠時間（秒）。如果未提供，則預設為類級別值
exponential_back_off_factor (float | None) – 決定下一次休眠時間的乘法因子。如果未提供，則預設為類級別值
max_retries (int | None) – 檢查複製組可用性的最大重試次數。如果未提供，則預設為類級別值
- 返回：
來自 ElastiCache delete replication group API 的響應
- 丟擲：
AirflowException – 如果複製組未被刪除
- 返回型別：
dict