加入限流策略。防止过度消耗资源
This commit is contained in:
@@ -12,6 +12,7 @@ from base.plugin_common.plugin_interface import PluginStatus
|
|||||||
from utils.compress_chat_data import compress_chat_data
|
from utils.compress_chat_data import compress_chat_data
|
||||||
from utils.decorator.plugin_decorators import plugin_stats_decorator
|
from utils.decorator.plugin_decorators import plugin_stats_decorator
|
||||||
from utils.decorator.points_decorator import plugin_points_cost
|
from utils.decorator.points_decorator import plugin_points_cost
|
||||||
|
from utils.decorator.rate_limit_decorator import group_feature_rate_limit
|
||||||
from utils.markdown_to_image import convert_md_str_to_image
|
from utils.markdown_to_image import convert_md_str_to_image
|
||||||
from utils.revoke.message_auto_revoke import MessageAutoRevoke
|
from utils.revoke.message_auto_revoke import MessageAutoRevoke
|
||||||
from utils.robot_cmd.robot_command import GroupBotManager, PermissionStatus
|
from utils.robot_cmd.robot_command import GroupBotManager, PermissionStatus
|
||||||
@@ -99,6 +100,7 @@ class MessageSummaryPlugin(MessagePluginInterface):
|
|||||||
|
|
||||||
@plugin_stats_decorator(plugin_name="群聊总结")
|
@plugin_stats_decorator(plugin_name="群聊总结")
|
||||||
@plugin_points_cost(10, "群聊总结消耗积分", FEATURE_KEY)
|
@plugin_points_cost(10, "群聊总结消耗积分", FEATURE_KEY)
|
||||||
|
@group_feature_rate_limit(max_per_minute=1, feature_key=FEATURE_KEY)
|
||||||
async def process_message(self, message: Dict[str, Any]) -> Tuple[bool, Optional[str]]:
|
async def process_message(self, message: Dict[str, Any]) -> Tuple[bool, Optional[str]]:
|
||||||
"""处理消息"""
|
"""处理消息"""
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user