Поделиться через

ExponentialRetry Класс

  • Ссылка

Экспоненциальная повторная попытка.

Создает объект экспоненциальной попытки. Для первой попытки используется initial_backoff. Последующие повторные попытки повторяются через initial_backoff + increment_power^retry_count секунд.

Наследование
azure.storage.queue._shared.policies.StorageRetryPolicy
ExponentialRetry

Конструктор

ExponentialRetry(initial_backoff: int = 15, increment_base: int = 3, retry_total: int = 3, retry_to_secondary: bool = False, random_jitter_range: int = 3, **kwargs: Any)

Параметры

Имя Описание
initial_backoff
int

Начальный интервал задержки (в секундах) для первой попытки.

значение по умолчанию: 15
increment_base
int

Базовый (в секундах) для увеличения initial_backoff на после первой повторной попытки.

значение по умолчанию: 3
retry_total
int

Максимальное число повторных попыток.

значение по умолчанию: 3
retry_to_secondary
bool

Следует ли повторить запрос на вторичный сервер, если это возможно. Это должно быть включено только для учетных записей RA-GRS, и могут обрабатываться потенциально устаревшие данные.

значение по умолчанию: False
random_jitter_range
int

Число в секундах, указывающее диапазон для дрожания или случайных значений для интервала отката. Например, random_jitter_range 3 приводит к тому, что интервал отката x будет варьироваться в диапазоне от x+3 до x-3.

значение по умолчанию: 3

Методы

configure_retries
get_backoff_time

Вычисляет продолжительности спящего режима перед повторным выполнением.
increment

Увеличьте счетчики повторных попыток.

Параметры Dict[str, Any]] — настраиваемые значения, относящиеся к операции приращения. :p aram PipelineRequest request: объект запроса конвейера. :p aram Optional[PipelineResponse]: объект ответа конвейера. ошибка :p aram: ошибка, обнаруженная во время запроса, или

Значение отсутствует, если ответ был успешно получен.
send
sleep

configure_retries 

configure_retries(request: PipelineRequest) -> Dict[str, Any]

Параметры

Имя Описание
request
Обязательно

get_backoff_time

Вычисляет продолжительности спящего режима перед повторным выполнением.

get_backoff_time(settings: Dict[str, Any]) -> float

Параметры

Имя Описание
settings
Обязательно
Dict[str, Any]]

Настраиваемые значения, относящиеся к времени задержки.

Возвращаемое значение

Тип Описание
float

Число с плавающей точкой, указывающее, сколько времени нужно ждать перед повторным выполнением запроса, или Значение None, указывающее, что повторная попытка не должна выполняться.

increment

Увеличьте счетчики повторных попыток.

Параметры Dict[str, Any]] — настраиваемые значения, относящиеся к операции приращения. :p aram PipelineRequest request: объект запроса конвейера. :p aram Optional[PipelineResponse]: объект ответа конвейера. ошибка :p aram: ошибка, обнаруженная во время запроса, или

Значение отсутствует, если ответ был успешно получен.

increment(settings: Dict[str, Any], request: PipelineRequest, response: PipelineResponse | None = None, error: AzureError | None = None) -> bool

Параметры

Имя Описание
settings
Обязательно
request
Обязательно
response
значение по умолчанию: None
error
значение по умолчанию: None

Возвращаемое значение

Тип Описание
bool

Исчерпаны ли повторные попытки.

send 

send(request)

Параметры

Имя Описание
request
Обязательно

sleep 

sleep(settings, transport)

Параметры

Имя Описание
settings
Обязательно
transport
Обязательно

Атрибуты

connect_retries

Максимальное число повторных попыток подключения.

connect_retries: int

increment_base

Базовый (в секундах) для увеличения initial_backoff на после первой повторной попытки.

increment_base: int

initial_backoff

Начальный интервал задержки (в секундах) для первой попытки.

initial_backoff: int

next

Указатель на следующую политику или транспорт (в оболочке в виде политики). Будет задан при создании конвейера.

next: HTTPPolicy[HTTPRequestType, HTTPResponseType]

random_jitter_range

Число в секундах, указывающее диапазон для дрожания или случайных значений для интервала отката.

random_jitter_range: int

retry_read

Максимальное число повторных попыток чтения.

retry_read: int

retry_status

Максимальное число повторных попыток состояния.

retry_status: int

retry_to_secondary

Следует ли повторить попытку для вторичной конечной точки.

retry_to_secondary: bool

total_retries

Максимальное число повторных попыток.

total_retries: int