Skip to main content

Complete GRPC sending

Closes the sending channel in a client or bidirectional stream

Function CompleteGRPCSending(Val Connection, Val StreamID) Export

ParameterCLI optionTypeRequiredDescription
Connection-ArbitraryConnection object
StreamID-StringStream Identifier
Returns

Map Of KeyAndValue - Processing result

Caution

NOCLI: this method is not available in CLI version

1C:Enterprise/OneScript code example
URL = "http://localhost:9101";
Login = "bayselonarrend";
Password = "12we...";

Authorization = New Structure(Login, Password);

ConnectionSettings = OPI_ClickHouse.GetGRPCConnectionSettings(URL, Authorization);
Connection = OPI_ClickHouse.CreateGRPCConnection(ConnectionSettings);
Timeout = 10000;

OpeningResult = OPI_ClickHouse.OpenGRPCStream(Connection, Timeout);

If Not OpeningResult["result"] Then
Raise OpeningResult["error"];
Else
StreamID = OpeningResult["streamId"];
EndIf;

QueryText = "SELECT number FROM system.numbers LIMIT 1";
Request = OPI_ClickHouse.GetRequestSettings(QueryText, , , , "JSON");

Sending = OPI_ClickHouse.SendGRPCMessage(Connection, StreamID, Request);
Result = OPI_ClickHouse.CompleteGRPCSending(Connection, StreamID);
Result
{
"result": true
}