records, unreadable_lines = load_logs(filename)
print(f"可转换记录：{len(records)} 条")
print(f"无法转换行：{len(unreadable_lines)} 行")

# 在这里自己定义 split_records(records)。
# 功能：按本课有效规则，把记录分到两个新列表中。
# 输入：读取工具已转换好的完整记录列表。
# 返回：valid_records, invalid_records，一次返回含两个列表的元组。
# 保持原来的先后顺序，不增删输入列表，不修改其中字典。
# 空输入返回两个空列表；全无效输入也必须保留全部无效记录。
# 升级第五课的 select_valid：这一次同时保留没有通过规则的记录。

import log_tools


# 在这里自己定义 analyze_logs(records, threshold_ms=1000, k=3)。
# 输入：读取工具已经转换好的完整记录列表、耗时阈值和 K。
# 任务1：调用 log_tools.split_records，接住有效与规则无效的两个列表。
# 任务2：只对有效记录调用 count_by_field，统计级别、IP、设备和事件。
# 任务3：统计不同 IP、不同设备的数量；统计达到耗时阈值的有效记录。
# 任务4：用 top_k 得到 IP 和事件排名，次数并列沿用首次出现顺序。
# 任务5：返回一个字典，键名按下面的约定填写：
# valid_records, invalid_records, level_counts, ip_counts,
# device_counts, event_counts, unique_ip_count, unique_device_count,
# ip_top, event_top, slow_count。
# 不修改传入记录，不读取文件，不在分析函数里打印整份报告。
# 空输入也返回完整字典：列表与排名为空列表，计数为空字典，数量为 0。


if __name__ == "__main__":
    print("请先完成 log_tools.py 中的 split_records，再写出本文件的 analyze_logs。")
    print("函数写好后，运行 observe_steps.py counts data/familiar.log 观察结果。")

def main(filename="data/practice.log", threshold_ms=1000, k=3):
    records, unreadable_lines = load_logs(filename)
    # 完成两个自写函数后，用下面两次调用替换末尾的三行提示。
    # report = analyzer.analyze_logs(records, threshold_ms, k)
    # show_report(filename, records, unreadable_lines, report, threshold_ms, k)
    print(f"已读取 {filename}：可转换 {len(records)} 条，无法转换 {len(unreadable_lines)} 行。")
    print("请完成 split_records 与 analyze_logs，再在 main 中连接分析和显示。")
    print("当前只完成读取，还没有产生分类统计结果。")