AWS Amplify - 同步数据存储

Question

我正在尝试构建一个原型应用程序来评估 AWS-Amplify (DataStore) 在我们的下一个应用程序中的使用情况。我在尝试同步 2 个客户端时遇到问题。我按照此处教程的说明设置了 AWS-DataStore： https: //docs.amplify.aws/lib/datastore/getting-started/q/platform/ios使用 Cocoapods。关于 Cocoapods，一切都按预期进行。我尝试了一些测试，这些测试也可以在上面的“操作数据”链接下看到。我还做了“将数据同步到云”部分。我可以在 AWS 控制台的 dynamoDB 中查看我的数据。当我添加条目时，我可以在控制台中看到它，一切都按预期工作，但我在两种情况下遇到问题：

假设我有 2 个客户端 A 和 B（都运行 iOS 13 - 无论是真实设备还是模拟器），我希望这些客户端保持同步。为此，我添加了一个 PostStore（我使用 atm 上方 AWS 链接中的示例架构），如下所示：

import Foundation
import Combine
import SwiftUI
import Amplify

class PostStore: ObservableObject {
    
    @Published private(set) var posts: [Post] = []
    
    var postSubscription: AnyCancellable?
    
    init() {
        self.getAllPostsFromDataStore()
    }
    
    deinit {
        self.unsubscribeFromDataStore()
    }
    
    func getAllPostsFromDataStore() {
        
        Amplify.DataStore.query(Post.self) { (result) in
            switch result {
            case .success(let posts):
                DispatchQueue.main.async {
                    print("Got \(posts.count) Posts from DataStore initially")
                    self.posts = posts
                }
            case .failure(let error):
                print("Error getting Posts from DataStore: \(error.localizedDescription)")
            }
        }
    }
    
    func addRandomPostToDataStore() {
        
        let post = Post.getRandomPost()
        self.addPostToArray(post)
        
        print("Fire: \(post.id)")
        
        Amplify.DataStore.save(post) {
            
            switch $0 {
            case .success(let post):
                print("Added post with id: \(post.id)")
            case .failure(let error):
                print("Error adding post with title: \(post.title) Error: \(error.localizedDescription)")
            }
        }
    }
    
    func deletePostFromDataStore(for indexSet: IndexSet) {
        
        let postsToDelete = indexSet.map { self.posts[$0] }
        
        self.posts.remove(atOffsets: indexSet)
        
        for post in postsToDelete {
            
            Amplify.DataStore.delete(post) { (result) in
                switch result {
                case .success():
                    print("Deleted Post from DataStore")
                case .failure(let error):
                    print("Error deleting Post From DataStore: \(error)")
                }
            }
        }
    }
        
    func subscribeToDataStore() {
        
        postSubscription = Amplify.DataStore.publisher(for: Post.self)
            .sink(receiveCompletion: { (completion) in

                print("Completion!")

                if case .failure(let error) = completion {
                    print("Subscription received Error: \(error.localizedDescription)")
                }

            }, receiveValue: { (changes) in
                
                
                //print("Subscription received mutation: \(changes)")
                print("\n\n\n")
                print("\(try! changes.toJSON())")
                print("\n\n\n")
//                print("Changes!")
                let newPost = try! changes.decodeModel(as: Post.self)

                DispatchQueue.main.async {

                    switch changes.mutationType {
                    case "create":
//                        print("Create Subscription")
                        self.addPostToArray(newPost)
                        break
                    case "update":
                        print("Update Subscription")
                        self.updatePostInArray(newPost)
                        break
                    case "delete":
                        print("Delete Subscription")
                        self.deletePostFromArray(newPost)
                        break
                    default:
                        print("AnotherType?")
                        print(changes.mutationType)
                        break
                    }
                }
                print("\n")
            })
    }
    
    func unsubscribeFromDataStore() {
        postSubscription?.cancel()
    }
    
    private func addPostToArray(_ post: Post) {
        
        if !self.posts.contains(post) {
            self.posts.append(post)
        }
    }
    
    private func deletePostFromArray(_ post: Post) {
        
        if let index = self.posts.firstIndex(of: post) {
            self.posts.remove(at: index)
        }
    }
    
    private func updatePostInArray(_ post: Post) {
        print("update?")
    }
}

该subscribeToDataStore方法是通过 SwiftUI-View（在 中onAppear）触发的，是这里的关键。如果我（缓慢地）向客户端 A 添加一些帖子，则客户端 B 会收到每个更改并将其添加到商店中（我使用 SwiftUI 视图将其可视化，但这在本例中并不重要）。这里没有问题，一切都按预期进行。

但

1. 当我使用客户端 A 非常快速地添加新条目（帖子）时，B 不会获取一些新条目。
2. 当我在客户端 B 离线（处于飞行模式）时添加超过 1 个条目并且我关闭飞行模式时，每次订阅只会获取最新条目。

在这两种情况下，当我触发时，getAllPostsFromDataStore每个条目都会被获取，我们很高兴再次开始。

所以我的问题是：为什么订阅没有获取每个条目？

在执行场景 1 时，有一个有趣的事实：接收每个订阅的条目时的常见日志消息如下所示：

WebsocketDidReceiveMessage - {MyObject}

然后我再次将对象记录在接收器“receiveValue”完成中：

{MyObject}

但是，当快速（在短时间内）添加一些条目时，来自 Amplify 的日志消息有时看起来像这样：（这就是订阅获取中缺少第一个“对象”的地方）：

WebsocketDidReceiveMessage - {MyObject}
WebsocketDidReceiveMessage - {MyObject2}

然后我再次将对象记录在接收器“receiveValue”完成中，并且只有最后一个对象被记录：

{MyObject2}

似乎{MyObject}在快速添加多个条目时被取消或发生其他情况。如上所述，当 B 处于飞行模式或没有连接时，仅获取最后添加的条目。（但我也只收到最后一条日志消息WebsocketDidReceiveMessage）。

我是否在这里遗漏了什么，或者这是 Amplify-DataStore SDK 中的错误？

请原谅我糟糕的英语。我不是母语人士，有时很难确切地说出问题是什么。如果您对此问题有任何疑问或需要更多信息，请发表评论，我将编辑我的问题，提供您需要的一切。

此致

Answer 1

对于也遇到过这个问题的人：

我在这里提交了一个问题，问题似乎在版本 1.3.1 中已通过 PR #756修复

玩得开心！