如何配置HKAnchoredObjectQuery以仅获取上次查询后的更新？

我之前也踩过这个坑，来给你把逻辑捋得明明白白：首先得明确HKQueryAnchor不是基于日期构建的，它是HealthKit内部维护的一个「位置标记」，用来跟踪你最后一次查询到的数据集边界，比手动存日期可靠得多——毕竟HealthKit的数据可能存在延迟写入、回溯修改的情况，日期过滤很容易漏数据或者重复获取。

1. 初始锚点的声明 #

第一次查询时你没有历史锚点，这时候可以用初始锚点HKQueryAnchor.init(fromValue: 0)——这个锚点会让查询返回所有符合条件的样本，同时在查询回调里，HealthKit会给你一个新的锚点，这个就是你后续要持久化的「最后查询位置」。

2. 锚点的持久化 #

因为HKQueryAnchor遵循NSSecureCoding协议，所以你可以用UserDefaults或者Core Data来持久化它。这里给个简单的UserDefaults实现示例：

存储锚点：

func saveAnchor(_ anchor: HKQueryAnchor) {
    do {
        let data = try NSKeyedArchiver.archivedData(withRootObject: anchor, requiringSecureCoding: true)
        UserDefaults.standard.set(data, forKey: "LastWorkoutQueryAnchor")
    } catch {
        print("Failed to save anchor: \(error.localizedDescription)")
    }
}

读取锚点：

func loadAnchor() -> HKQueryAnchor? {
    guard let data = UserDefaults.standard.data(forKey: "LastWorkoutQueryAnchor") else {
        return nil // 第一次查询返回nil，后续用初始锚点
    }
    do {
        return try NSKeyedUnarchiver.unarchivedObject(ofClass: HKQueryAnchor.self, from: data)
    } catch {
        print("Failed to load anchor: \(error.localizedDescription)")
        return nil
    }
}

3. 完整的updateWorkouts函数示例 #

把这些逻辑整合到你的查询里，就能实现只返回自上次查询后的新增样本：

func updateWorkouts(completionHandler: @escaping (Result<[HKWorkout], Error>) -> Void) {
    guard let workoutType = HKObjectType.workoutType() else {
        completionHandler(.failure(NSError(domain: "YourAppDomain", code: -1, userInfo: [NSLocalizedDescriptionKey: "Workout type not available"])))
        return
    }
    
    // 加载上次存储的锚点，没有则用初始锚点
    let anchor = loadAnchor() ?? HKQueryAnchor(fromValue: 0)
    
    // 替换成你需要的查询条件，比如指定运动类型、时间范围等
    let predicate = HKQuery.predicateForWorkouts(with: .walking)
    let query = HKAnchoredObjectQuery(type: workoutType,
                                      predicate: predicate,
                                      anchor: anchor,
                                      limit: HKObjectQueryNoLimit) { query, newSamples, deletedObjects, newAnchor, error in
        DispatchQueue.main.async {
            if let error = error {
                completionHandler(.failure(error))
                return
            }
            
            // 保存新锚点，下次查询就从这个位置开始
            if let newAnchor = newAnchor {
                self.saveAnchor(newAnchor)
            }
            
            // newSamples就是自上次查询以来新增的样本
            let workouts = newSamples as? [HKWorkout] ?? []
            completionHandler(.success(workouts))
        }
    }
    
    // 如果需要实时监听新增数据，可以设置updateHandler
    query.updateHandler = { query, newSamples, deletedObjects, newAnchor, error in
        DispatchQueue.main.async {
            if let error = error {
                print("Update handler error: \(error.localizedDescription)")
                return
            }
            
            if let newAnchor = newAnchor {
                self.saveAnchor(newAnchor)
            }
            
            let newWorkouts = newSamples as? [HKWorkout] ?? []
            // 这里可以处理实时新增的训练数据，比如通知UI更新
            print("Received \(newWorkouts.count) new workouts")
        }
    }
    
    HKHealthStore().execute(query)
}

关键误区澄清 #

你完全不需要手动存储上次下载样本的日期——HealthKit的锚点已经帮你精准跟踪了查询位置，持久化newAnchor就足够了。如果用日期过滤，可能会遇到用户手动添加几天前训练数据的情况，这时候锚点依然能捕获到这些回溯数据，而日期过滤就会直接漏掉。

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