go、grpc、postgresを使ってタスクリストを作成しています。
postitem
を呼び出して新しいデータを挿入するときにデータを自動的にストリーミングするにはどうすればよいですか? postgres をサブスクライブする必要がありますか、それともサブスクライブまたはパブリッシュ・サブスクライブなしでこれを実行できますか?
//protobuf アーキテクチャ
リーリー// postgres テーブル構造
リーリー ###// 続く###syntax = "proto3"; package tasklist; import "google/protobuf/empty.proto"; service todolist { rpc gettasks(google.protobuf.empty) returns (stream gettasksresponse) {} rpc postitem(postitemrequest) returns (posttaskrequest) {} } message task { int64 id = 1; string name = 2; } message gettasksresponse { task task = 1; } message posttaskrequest { task task = 1; } message postitemresponse { bool result = 1; }
はchan task
と似ていると思います。したがって、正常に完了したら // ここで postgres を更新します
リクエストを chan で送信できます。
リーリー
以上がgRPC を使用してテーブル変更直後にデータベース データを転送するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。