如何查询数千个值并仅返回数组中的值 - Firebase Swift

Question

在 firebase 实时数据库中，我有这样的数据：

"users" : {
"37KfZKDwrieIEKI9juAC4Xm8aPi1" : {
  "isConnected" : false,
  "isGuestUser" : false,
  "lastOnline" : 1510250272022,
  "profilePicture" : "5a039030515e78653148",
  "userID" : "37KfZKDwrieIEKI9juAC4Xm8aPi1",
  "username" : "adsfasdfasdf"
},
"4D1GNiRH5NeRxpmTNg6JhJ3iTck1" : {
  "isConnected" : false,
  "isGuestUser" : true,
  "lastOnline" : 1510077502788,
  "profilePicture" : "5a01f2648278b6652011",
  "userID" : "4D1GNiRH5NeRxpmTNg6JhJ3iTck1",
  "username" : "ihoho"
},
"5UA3INZ7i0dnNtgX0ai5ABhjxh43" : {
  "isConnected" : false,
  "isGuestUser" : true,
  "lastOnline" : 1512610102474,
  "profilePicture" : "5a14df775a34f2388873",
  "userID" : "5UA3INZ7i0dnNtgX0ai5ABhjxh43",
  "username" : "jlkjlkjlkj"
},...

我正在使用一个外部 API，它返回一个看起来像这样的 Json

"candidates" : [
    {
      "enrollment_timestamp" : "1510182689539",
      "subject_id" : "37KfZKDwrieIEKI9juAC4Xm8aPi1",
    },
    {
      "enrollment_timestamp" : "1513557650425",
      "subject_id" : "CKUVZ7XtY9VKJakn1lBV7MVW1702",
    },
    {
      "enrollment_timestamp" : "1507578748901",
      "subject_id" : "l7VDdtGFpMe8BRbrlCyAciTvONk1",
    },...

最终目标是从 json 中获取所有在线的外部 api 用户。这需要监听每个用户的“isConnected”端点，并确定它是真还是假。

现在使用 firebase 和我当前的数据结构这是不可能的，因为首先 firebase 不支持多个查询参数，所以我不能做 where userID = subjectID && where isConnected == true，其次，更重要的是，firebase 不允许我做相当于 WHERE IN，即将用户 ID 映射到客户端提供的潜在用户 ID 数组（仅供参考 subjectID === userID）

所以我所做的就是像这样重组我的数据；

"onlineUsers" : {
"Aze1x7jTZIbPyyPmlUYWVdEyAd73" : true,
"CQdmMxkmqBerRGOQpFblx7SO4D33" : true,
"EptMK62Kt1Sp1EIb5meuKHVpUqs1" : true,
"J2X65KauDlSvkN4Yp5V4IF0sTnx1" : true,
"KnYEqsekY9YXV3ayOx082xw8VQX2" : true,
"aGLrKH31YvRKrB8KYQmZ4sA122m1" : true,
"ab3JZyw9YMdpW3mXkZc2BjYkxej2" : true,
"gpQic1EzSnXL9x5DhaoXxcWrGF22" : true,
"qQaBPMaDOrXrWddsijfMJWusuGG3" : true,
"tDWEUoKS4mUdQ1bWeiLTlhwCSoD3" : true

},

现在，要获取外部 api json 中的所有在线用户，我所要做的就是查询 onlineUsers 并通过键检查条件参数。这样我就知道结果是否为空，用户不在线：

    static func queryDatabase(child: String, queryEqual: String, keyOf: Int, completionHandler: @escaping (_ return: AnyObject?, _ error: String?) -> Void){
    print("querying db with child ", child)

    let ref = databaseReference.child(child).queryOrderedByKey().queryEqual(toValue: queryEqual)

     ref.observe(.value, with:{ (snapshot: DataSnapshot) in
        print("subjectID: ", queryEqual, "at key ", keyOf)
        print("queryResult", snapshot)

        if let value =  (snapshot.value as? [String: AnyObject])?[queryEqual] {
            print("unwrapped snapshot dict value from key: ", value)

            completionHandler(value,  nil)

        }else{
            print("no value for key \(queryEqual) so setting return as nil")

            completionHandler(nil,  nil)

        }



    }){ (error) in
        print(error.localizedDescription)

        completionHandler(nil,  error.localizedDescription )


    }

}

通过循环外部 api json 调用这个函数很简单，每次迭代调用这个函数 ^^，类似于：

      for (key, valueSubjectID) in arrayOfOrderedMatches.enumerated(){
         //call function queryDatabase here

    queryDatabase(child: "onlineUsers", queryEqual: valueSubjectID, keyOf: key, completionHandler:{ (response, error) in


//it would return the user if they were online here


)}
    }

现在。这行得通。在浏览互联网并考虑所有可能性后，这是我能想到的最有效的方法。但是，现在遇到一个大问题：来自 api 的 json 可能有成千上万的用户。这意味着将连接数以千计的听众来检查每个单独的用户，看看他们是否在线。正如 Firebase 开发人员告诉我的那样，这并不理想。我不应该附上成千上万的听众。此外，由于某种原因，听众在 3500 左右停止添加，我猜是因为它出错了。如果查询返回 null （即脱机），我无法删除侦听器，因为缓存脱机持久性的工作方式，即使我可以，我也不认为这会解决问题。有什么办法可以解决这个问题吗？

Answer 1

让我重申一下目标。

为应用提供了大量用户 ID（如 JSON），目标是了解哪些用户在线。

这里有两个选项：

我们从用户节点开始

users
  uid_0
    name: "Frank"
    online: true
  uid_1
    name: "Jeff"
    online: false

当接收到我们要检查的用户的 JSON 时，我们将其转换为 Array 以便于访问。

那么，我们有几个选择

1) 遍历数组并为每个 uid 观察SingleEvent 以获取其当前状态。这不会是一个查询，因为我们可以直接访问 uid，因此与查询相比它会相当轻量级。*

let arrayToTest = [String]() //the array of uid's to test
for uid in arrayToTest {
    let thisUserRef = self.ref.child("users").child(uid)
    thisUserRef.observeSingleEvent(of: .value, with: { snapshot in
        let dict = snapshot.value as! [String: Any]
        let status = dict["online"] as! Bool
        print("uid: \(uid) online status is: \(status)")
    })
}

2) 让 Firebase 完成繁重的工作，方法是向用户节点添加一个 .childAdded 事件，该事件将一次遍历所有用户。

将快照中的 uid 与数组中的 uid 进行比较，如果匹配，则获取其状态（在线/离线），如果数组中不存在，则忽略它。

let usersRef = self.ref.child("users")
let arrayToTest = [String]() //the array of uid's to test
usersRef.observe(.childAdded, with: { snapshot in
    let dict = snapshot.value as! [String: Any]
    let uid = dict["user_id"] as! String
    if arrayToTest.contains(uid) {
        let status = dict["online"] as! Bool
        print("uid: \(uid) online status is: \(status)")
    }
})

选项 2) 通常会更好，因为它一次只加载一个，而 Firebase 正在完成所有工作 - 我们只是检查快照中的 uid 是否存在于代码中。

3)

作为第三种选择，我们可以利用查询。请注意，在前两个选项中，我们使用轻量级观察函数检索数据。相比之下，查询更繁重并占用更多资源 - 但是，快照结果仅限于那些已登录的用户，如果有大量用户可能是最佳选择。

let usersRef = self.ref.child("users")
let queryRef = usersRef.queryOrdered(byChild: "online").queryEqual(toValue: true)
let arrayToTest = [String]() //the array of uid's to test
queryRef.observe(.childAdded, with: { snapshot in
    let dict = snapshot.value as! [String: Any]
    let uid = dict["user_id"] as! String
    if arrayToTest.contains(uid) {
        print("uid: \(uid) online status is: true")
    }
})

*Firebaser 对 1) 会皱眉头，因为他们强烈建议不要在紧密循环中进行观察。所以 2）如果您想确认每个用户都存在，以及 3）如果您只对在线用户感兴趣。