commands.py中的函数解析5：clear_orphaned_file_records等
输入“/”快速插入内容
commands.py中的函数解析5：clear_orphaned_file_records等
commands.py中的函数解析5：clear_orphaned_file_records等
用户4443用户44432025年6月30日修改
本文使用Dify v1.4.0版本，主要解析了commands.py中的clear_free_plan_tenant_expired_logs、clear_orphaned_file_records和remove_orphaned_files_on_storage等函数的执行逻辑。源码位置：dify\api\commands.py
一.clear_free_plan_tenant_expired_logs()函数
完整的执行命令示例，如下所示：
代码块
flask clear-free-plan-tenant-expired-logs --days 30 --batch 100 --tenant_ids 1 2 3
•
--days：要清理的天数（如 30）
•
--batch：每批处理的数量（如 100）
•
--tenant_ids：要清理的租户 ID，可以指定多个（如 1 2 3）
该段代码定义了一个命令行工具命令 clear-free-plan-tenant-expired-logs，用于清理免费套餐租户过期的日志。支持自定义天数、批量大小和租户范围，适合运维人员在命令行下操作。
代码块
@click.command("clear-free-plan-tenant-expired-logs", help="Clear free plan tenant expired logs.")
@click.option("--days", prompt=True, help="The days to clear free plan tenant expired logs.", default=30)
@click.option("--batch", prompt=True, help="The batch size to clear free plan tenant expired logs.", default=100)
@click.option(
"--tenant_ids",
prompt=True,
multiple=True,
help="The tenant ids to clear free plan tenant expired logs.",
)
def clear_free_plan_tenant_expired_logs(days: int, batch: int, tenant_ids: list[str]):
"""
Clear free plan tenant expired logs.
"""
click.echo(click.style("Starting clear free plan tenant expired logs.", fg="white"))
ClearFreePlanTenantExpiredLogs.process(days, batch, tenant_ids)
click.echo(click.style("Clear free plan tenant expired logs completed.", fg="green"))
1.命令定义
使用 @click.command 装饰器注册命令名为 clear-free-plan-tenant-expired-logs，并添加帮助说明。
2.参数定义
•
--days：需要用户输入，表示要清理多少天前的日志，默认30天。
•
--batch：需要用户输入，表示每批处理的日志数量，默认100。
•
--tenant_ids：需要用户输入，可以输入多个租户ID，指定要清理哪些租户的日志。
3.函数实现
•
首先输出"开始清理免费套餐租户过期日志"的提示信息。
•
调用 ClearFreePlanTenantExpiredLogs.process(days, batch, tenant_ids) 方法，执行实际的清理逻辑。该方法会根据传入的天数、批量大小和租户ID列表，处理并清理对应的日志。
•
清理完成后，输出"清理完成"的提示信息。
二.clear_free_plan_tenant_expired_logs.py
该 process 方法用于清理免费套餐租户的过期日志。它支持并发处理多个租户，自动分批，动态调整批次大小。
执行流程：指定租户或自动分批处理所有租户；采用线程池并发处理，提升效率；动态调整批次大小，避免单批过大；只处理免费套餐租户，异常有日志记录；处理进度定期输出。
1.方法入口与初始化