在GAE/P中构建自定义用户活动日志的实现方案问询

这是一个非常贴合企业级场景的活动日志需求，基于你提到的ndb模型思路，我来帮你完善方案并给出一些实用的实践建议：

首先把你提到的模型补全，重点强化企业层级查询的支撑能力：

from google.appengine.ext import ndb
from enum import Enum
import datetime

# 用枚举规范活动类型，避免拼写错误
class ActivityType(Enum):
    LOGIN = "login"
    DOCUMENT_UPLOAD = "document_upload"
    PERMISSION_CHANGE = "permission_change"
    TASK_ASSIGN = "task_assign"

class Activity(ndb.Model):
    # 活动类型（必填）
    activity_type = ndb.StringProperty(required=True, choices=[e.value for e in ActivityType])
    # 触发活动的用户ID（必填）
    user_id = ndb.StringProperty(required=True)
    # 用户所属企业ID（核心！支撑企业层级查询）
    enterprise_id = ndb.StringProperty(required=True)
    # 活动发生时间（自动生成，无需手动设置）
    created_at = ndb.DateTimeProperty(auto_now_add=True)
    # 活动详情（存储结构化数据，比如上传文件名、权限变更内容）
    details = ndb.JsonProperty()
    # 可选：操作的目标资源ID（比如被修改的文档ID、被分配的任务ID）
    target_resource_id = ndb.StringProperty()

针对你需要的三个展示层级，给出对应的查询逻辑，同时注意索引优化：

• 单个用户的活动查询：

  def get_user_activities(user_id, limit=50, offset=0):
      # 按时间倒序，取最新的活动
      return Activity.query(Activity.user_id == user_id)\
                      .order(-Activity.created_at)\
                      .fetch(limit, offset=offset)
  

  这里需要在index.yaml中配置复合索引：

  indexes:
  - kind: Activity
    properties:
    - name: user_id
    - name: created_at
      direction: desc
  

• 某企业所有用户的活动查询：

  def get_enterprise_activities(enterprise_id, limit=100, offset=0):
      return Activity.query(Activity.enterprise_id == enterprise_id)\
                      .order(-Activity.created_at)\
                      .fetch(limit, offset=offset)
  

  对应的复合索引：

  indexes:
  - kind: Activity
    properties:
    - name: enterprise_id
    - name: created_at
      direction: desc
  

• 全部活动查询：

  def get_all_activities(limit=200, offset=0):
      # 单属性索引ndb会自动创建，无需手动配置
      return Activity.query().order(-Activity.created_at).fetch(limit, offset=offset)
  

1. 批量写入优化：如果存在高频活动（比如用户频繁点击操作），建议用ndb.put_multi()批量写入日志，减少RPC调用次数，提升性能。
2. 日志归档策略：随着业务增长，日志数据会越来越多，建议把超过90天的旧日志归档到Cloud Storage或BigQuery，只保留最近的活跃日志在ndb中，避免主存储查询变慢。
3. 权限校验：查询日志时一定要加权限控制，比如普通用户只能查自己的日志，企业管理员只能查本企业的日志，绝对不能让用户跨企业查询数据。
4. 错误处理：写入日志时建议用异步任务或者捕获异常，避免日志写入失败影响主业务流程。

内容的提问来源于stack exchange，提问作者minou