Verwenden Sie gRPC, um Datenbankdaten unmittelbar nach Tabellenänderungen zu übertragen

Frageninhalt

Ich erstelle eine Aufgabenliste mit go, grpc und postgres.

Wie streame ich automatisch Daten, wenn ich postitem anrufe, um neue Daten einzufügen? Muss ich Postgres abonnieren oder kann dies ohne Abonnement oder Veröffentlichungsabonnement erfolgen?

//Protobuf-Architektur

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

// Postgres-Tabellenstruktur

create table task (
  id integer not null primary key,
  name varchar(10) not null
);

// Weiter

func (s *server) GetTasks(_ *empty.Empty, stream pb.TaskList_GetTasksServer) error {
    // How can I steam data as soon as `PostTask` is called to update db? <- <-
    for _, r := range s.requests {
        // stream data
    }
}

func (s *server) PostTask(ctx context.Context, r *pb.PostTaskRequest) (*pb.PostTaskResponse, error) {
    // update Postgres here
    return &pb.PostItemResponse{Result: true}, nil
}

Richtige Antwort

Ich schätze s.requests 类似于 chan task。因此，在成功 // update postgres here Danach kannst du deine Anfrage per Kanal senden.

func (s *server) PostTask(ctx context.Context, r *pb.PostTaskRequest) (*pb.PostTaskResponse, error) {
    postTask := toDomain(r)
    err := s.service.UpdateTask(ctx, postTask)
    if err != nil {
        return nil, status.Error(codes.Internal, err.Error())
    }
    s.requests <- postTask
    return &pb.PostItemResponse{Result: true}, nil
}

Das obige ist der detaillierte Inhalt vonVerwenden Sie gRPC, um Datenbankdaten unmittelbar nach Tabellenänderungen zu übertragen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!