Обработать получение GRPC

Инициализирует поток, передает запрос и получает сообщения до закрытия или установленного лимита

Параметры

Функция ОбработатьПолучениеGRPC(Знач Соединение, Знач Запрос, Знач ЧислоСообщений = Неопределено, Знач Сессия = Неопределено, Знач Таймаут = 10000) Экспорт

Параметр	CLI опция	Тип	Обяз.	Назначение
Соединение	--conn	Произвольный	✔	Существующее соединение или параметры соединения
Запрос	--req	Структура Из КлючИЗначение	✔	Данные запроса. См. ПолучитьНастройкиЗапроса
ЧислоСообщений	--amount	Число	✖	Максимально число сообщений для получения, если необходимо
Сессия	--session	Структура Из КлючИЗначение	✖	Настройки сессии. См. ПолучитьНастройкиСессии
Таймаут	--tout	Число	✖	Таймаут (в мс)

Возвращаемое значение

Соответствие Из КлючИЗначение - Результат обработки

Расширенный вызов ?

Параметр	Описание
dontwait	Создает фоновое задание и возвращает его данные (только для 1С и OneScript)

Пример использования для 1С:Предприятие/OneScript

    URL = "http://localhost:9101";
    Логин  = "bayselonarrend";
    Пароль = "12we...";

    Авторизация         = Новый Структура(Логин, Пароль);
    НастройкиСоединения = OPI_ClickHouse.ПолучитьНастройкиСоединенияGRPC(URL, Авторизация);
    Соединение          = OPI_ClickHouse.ОткрытьСоединениеGRPC(НастройкиСоединения);

    ТекстВыборки = "SELECT * FROM events_stream_test ORDER BY id";
    Запрос       = OPI_ClickHouse.ПолучитьНастройкиЗапроса(ТекстВыборки, , , , "JSON");

    Результат = OPI_ClickHouse.ОбработатьПолучениеGRPC(Соединение, Запрос);

Bash

    # JSON данные также могут быть переданы как путь к файлу .json
    
    oint clickhouse ОбработатьПолучениеGRPC \
      --conn "{'address':'http://127.0.0.1:9101','auth_type':'basic','password':'***','transport':'grpc','user':'bayselonarrend'}" \
      --req "{'query':'SELECT * FROM events_stream_test ORDER BY id','format':'JSON'}"

CMD/Bat

    :: JSON данные также могут быть переданы как путь к файлу .json
    
    oint clickhouse ОбработатьПолучениеGRPC ^
      --conn "{'address':'http://127.0.0.1:9101','auth_type':'basic','password':'***','transport':'grpc','user':'bayselonarrend'}" ^
      --req "{'query':'SELECT * FROM events_stream_test ORDER BY id','format':'JSON'}"

Результат

{
 "stop_message": {
  "error": "Closed",
  "result": false
 },
 "result": true,
 "messages": [
  {
   "message": {
    "cancelled": false,
    "exception": {
     "code": 0,
     "display_text": "",
     "name": "",
     "stack_trace": ""
    },
    "extremes": "<Двоичные данные>",
    "logs": [],
    "output": {
     "meta": [
      {
       "name": "id",
       "type": "UInt64"
      },
      {
       "name": "timestamp",
       "type": "DateTime"
      },
      {
       "name": "user_id",
       "type": "UInt32"
      },
      {
       "name": "event_type",
       "type": "String"
      },
      {
       "name": "payload",
       "type": "String"
      }
     ],
     "data": [
      {
       "id": "1",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 100,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "1",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 100,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "1",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 100,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "1",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 100,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "2",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 101,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "2",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 101,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "2",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 101,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "2",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 101,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "3",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 102,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "3",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 102,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "3",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 102,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "3",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 102,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "4",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 103,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "4",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 103,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "4",
       "timestamp": "2026-01-01 10:00:00",
       "user_id": 103,
       "event_type": "stream_test",
       "payload": "{}"
      },
      {
       "id": "4",
       "timestamp": "2026-01-01 10:00:00",
...