ホームページ  >  記事  >  バックエンド開発  >  gRPC を使用してテーブル変更直後にデータベース データを転送する

gRPC を使用してテーブル変更直後にデータベース データを転送する

WBOY
WBOY転載
2024-02-05 11:49:31421ブラウズ

表更改后立即使用 gRPC 传输数据库数据

質問内容

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;
}

正解


s.requests

chan taskと似ていると思います。したがって、正常に完了したら // ここで postgres を更新します リクエストを chan で送信できます。 リーリー

以上がgRPC を使用してテーブル変更直後にデータベース データを転送するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明:
この記事はstackoverflow.comで複製されています。侵害がある場合は、admin@php.cn までご連絡ください。