超过django getstream的最大重试次数

# settings.py
GETSTREAM_SETTINGS = {
    'API_KEY': 'your-api-key',
    'API_SECRET': 'your-api-secret',
    'RETRY_STRATEGY': 'exponential_backoff',  # 使用指数退避策略
    'MAX_RETRIES': 10,  # 最大重试次数
}

import logging

logger = logging.getLogger(__name__)

def send_message():
    try:
        # 发送消息的代码
        pass
    except Exception as e:
        logger.error(f"Failed to send message: {e}")
        raise

from getstream import Stream
import logging

logger = logging.getLogger(__name__)

def send_activity(user_id, activity_data):
    stream = Stream(api_key='your-api-key', api_secret='your-api-secret')
    retries = 3
    for i in range(retries):
        try:
            stream.activity.create(user_id=user_id, activity_data=activity_data)
            break
        except Exception as e:
            if i == retries - 1:
                logger.error(f"Failed to send activity after {retries} retries: {e}")
                raise
            else:
                logger.warning(f"Failed to send activity, retrying ({i+1}/{retries}): {e}")
                time.sleep(2 ** i)  # 指数退避

# 调用函数
send_activity('user123', {'verb': 'like', 'object': 'post456'})