DaJet Stream: HTTP сервисы

15.03.24

Интеграция - WEB-интеграция

Команда REQUEST языка запросов DaJet Stream.

Основная статья про DaJet Stream

DaJet Stream: RabbitMQ

DaJet Stream: Apache Kafka

Видео: основы DaJet Stream

Видео: знакомство с платформой DaJet

Дистрибутив DaJet 3.3.3 на GitHub

Команда REQUEST в языке запросов DaJet Stream предназначена для выполнения http/s запросов, интеграции различных web api и того подобного. Она может быть добавлена в скрипт обмена данными совместно с другими командами DaJet Stream в нужной для решения задачи комбинации.

Вариантов использования http запросов огромное количество. Поэтому для ознакомления с функционалом команды REQUEST ниже будет приведён только один из возможных сценариев её использования.

Внимание! Команда REQUEST выполняется синхронно.

DECLARE @response object -- Переменная для ответа на HTTP запрос

REQUEST 'http://localhost/1c/hs/test/query'
   WITH User-Agent   = 'DaJet Stream'
      , Content-Type = 'text/plain; charset=utf-8'
 SELECT Method  = 'POST'    -- HTTP метод запроса
      , OnError = 'break'   -- break или continue
      , Content = 'Привет!' -- Тело HTTP запроса
   INTO @response           -- { "Code": "200", "Value": "text" }

Описание синтаксиса команды REQUEST

REQUEST - URL запроса, может быть динамическим шаблоном (см. пример ниже)

WITH - стандартные или пользовательские заголовки HTTP запроса

SELECT - опции процессора DaJet Stream для выполнения HTTP запроса

  • Method - стандартный метод HTTP запроса (GET, POST и т.д.)
  • OnError - стратегия обработки ошибок (необязательна, значение по умолчанию: break)
    • break - вызвать исключение и прервать выполнение конвейера обмена данными
    • continue - сохранить данные об ошибке и передать управление следующей команде
  • Content - тело HTTP запроса (текстовый формат, кодировка UTF-8)

INTO - переменная объектного типа (object), в которую возвращается результат выполнения запроса

 

Доступные свойства HTTP ответа  (переменная response из скрипта выше) 

Свойство Тип данных Описание
Code string Стандартный код HTTP ответа
Value string Тело HTTP ответа

 

 

 

 

 

В следующем сценарии используется регистр сведений "ИсходящиеЗапросы", который используется для асинхронной отправки HTTP запросов и логирования полученных ответов. Реквизит "Попытка" используется для контроля количества неуспешных выполнений, чтобы такие запросы не выполнять бесконечно.

 

Регистр сведений "ИсходящиеЗапросы"

Свойство Наименование Тип данных Описание
Измерение Статус

Перечисление

"СтатусыЗапросов"

Статус выполнения HTTP запроса
Измерение Идентификатор

Уникальный

идентификатор

Идентификатор запроса
Ресурс Адрес Строка(1024) URL HTTP сервиса
Ресурс Метод Строка(10) Метод HTTP запроса
Ресурс Тело Строка(0) Тело HTTP запроса для отправки
Реквизит Результат Строка(3) Стандартный HTTP код ответа
Реквизит Ответ Строка(0) Тело ответа HTTP сервиса
Реквизит Попытка Число(2,0) Количество выполнений запроса

 

Состояние регистра до выполнения скрипта DaJet Stream

 

Скрипт DaJet Stream

DECLARE @sender   string = 'DaJet Stream'
DECLARE @source   string = 'mssql://zhichkin/dajet-exchange'
DECLARE @request  object -- параметры http-запроса
DECLARE @response object -- код и тело http-ответа

-- ***************************************************************
-- * Источник HTTP запросов, регистр сведений "ИсходящиеЗапросы" *
-- ***************************************************************
USE '{@source}'

STREAM Идентификатор, Адрес, Метод, Тело, Попытка
  INTO @request
  FROM РегистрСведений.ИсходящиеЗапросы
 WHERE Статус  = Перечисление.СтатусыЗапросов.Новый
    OR Статус  = Перечисление.СтатусыЗапросов.Ошибка
   AND Попытка < 5

-- ***************************************************************
-- * СИНХРОННЫЙ вызов HTTP сервисов согласно заданным параметрам *
-- ***************************************************************

REQUEST '{@request.Адрес}'
   WITH User-Agent   = @sender
      , Content-Type = 'application/json; charset=utf-8'
 SELECT OnError = 'continue'     -- continue или break
      , Method  = @request.Метод -- HTTP метод запроса
      , Content = @request.Тело  -- Тело HTTP запроса
   INTO @response -- { "Code": "200", "Value": "text" }

-- ************************************************************************
-- * Журналирование результатов выполнения HTTP запросов в базе-источнике *
-- ************************************************************************

UPDATE РегистрСведений.ИсходящиеЗапросы
 WHERE Идентификатор = @request.Идентификатор -- Идентификатор HTTP запроса
   SET Результат     = @response.Code         -- HTTP код ответа (строка)
     , Ответ         = @response.Value        -- Тело HTTP ответа (строка)
     , Попытка       = @request.Попытка + 1.0 -- Счётчик попыток
     , Статус        = CASE WHEN @response.Code = '200' -- Код HTTP ответа
                            THEN Перечисление.СтатусыЗапросов.Успех
                            ELSE Перечисление.СтатусыЗапросов.Ошибка END

Выполнение скрипта в среде Windows

(из корневого каталога установки)

dajet stream --file ./stream/script.sql

Выполнение скрипта в среде Linux

(из корневого каталога установки)

dotnet ./dajet.dll stream --file ./stream/script.sql

 

Состояние регистра после выполнения скрипта 5 и более раз

 

DaJet Stream обмен данными интеграция http-сервисы

См. также

Интеграция Альфа Авто 5 / Альфа Авто 6 и AUTOCRM / Инфотек

Сайты и интернет-магазины WEB-интеграция Системный администратор Программист Пользователь Платформа 1С v8.3 Конфигурации 1cv8 1С:Управление торговлей 11 Автомобили, автосервисы Россия Управленческий учет Платные (руб)

Интеграционный модуль обмена между конфигурацией Альфа Авто 5 и Альфа Авто 6 и порталом AUTOCRM. Данный модуль универсален. Позволяет работать с несколькими обменами AUTOCRM разных брендов в одной информационной базе в ручном и автоматическом режиме.

36000 руб.

03.08.2020    16275    14    18    

14

Интеграция 1С и Битрикс 24 — модуль синхронизации для обмена задачами

Сайты и интернет-магазины Интеграция WEB-интеграция Платформа 1С v8.3 Конфигурации 1cv8 Управленческий учет Платные (руб)

Интеграция 1С и Битрикс 24. Разработка имеет двухстороннюю синхронизацию 1С и Bitrix24 задачами. Решение позволяет создавать пользователя в 1С из Битрикс24 и наоборот. Данная разработка технически подходит под все основные конфигурации линейки продуктов 1С:Предприятие 8.3 (платформа начиная с 8.3.23). При приобретении предоставляется 1 месяц бесплатных обновлений разработки. Доступна демо-версия продукта с подключением Вашего Битрикс24

5040 руб.

04.05.2021    18466    10    15    

16

Модуль для обмена "1С:Предприятие 8. УАТ. ПРОФ" с FortMonitor

WEB-интеграция 8.3.8 Конфигурации 1cv8 Автомобили, автосервисы Беларусь Украина Россия Казахстан Управленческий учет Платные (руб)

Расширение предназначено для конфигурации "1С:Предприятие 8. Управление Автотранспортом. ПРОФ". Функционал модуля: 1. Заполнение регистров сведений по подсистеме "Мониторинг", а именно: события по мониторингу, координаты по мониторингу, пробег и расход по мониторингу, текущее местоположение ТС по мониторингу 2. Заполнение путевого листа: пробег по мониторингу, время выезда/заезда, табличная часть ГСМ, места стоянок по геозонам. 3. Отчеты по данным загруженным в регистры сведений. 4. Предусмотрена автоматическая загрузка данных в фоновом режиме (условия работы данной загрузке читайте в описании товара) Модуль работает без включенной константы по настройкам мониторинга. Модуль формы предоставляется с открытым кодом, общий модуль защищен. Любой заинтересованный пользователь, имеет возможность скачать демо-версию расширения.

22656 руб.

25.05.2021    13116    34    8    

13

Автоматическая загрузка файлов (например, прайс-листов) из электронной почты, FTP, HTTP, их обработка и выгрузка на FTP (на сайт) и для других целей

Прайсы WEB-интеграция Ценообразование, анализ цен Файловый обмен (TXT, XML, DBF), FTP Системный администратор Программист Автомобили, автосервисы Оптовая торговля, дистрибуция, логистика Управленческий учет Платные (руб)

Программа с заданным интервалом времени (или по ручной команде) скачивает файлы (например, прайс-листы поставщиков) из различных источников: письма электронной почты, FTP или HTTP-адреса, и сохраняет их в каталог упорядоченной структуры. При этом извлекает файлы из архивов, может переименовывать файлы и менять их формат (csv, xls, txt). Можно настроить выгрузку обработанных файлов на сайт (через FTP-подключение). Программа будет полезна компаниям, у которых есть большое количество поставщиков и/или прайс-листы поставщиков обновляются часто (необязательно прайс-листы, файлы могут быть любого назначения). Собранные таким образом актуальные версии прайс-листов можно выгрузить с помощью программы себе на сайт (или на любой FTP-сервер) или выполнить другие необходимые задачи.

25200 руб.

28.05.2015    85807    26    51    

50
Комментарии
Подписаться на ответы Инфостарт бот Сортировка: Древо развёрнутое
Свернуть все
1. alex_bob 246 29.03.24 09:12 Сейчас в теме
Если я получил в ответе на запрос json с массивом объектов внутри, можно ли мне как-то дальше в скрипте загнать этот массив во временную таблицу?
2. zhichkin 1460 04.04.24 19:58 Сейчас в теме
(1) Хороший вопрос. Я думал над этим и пока отложил реализацию такой безусловно полезной возможности.
Сейчас это реализовано в языке запросов DaJet следующим образом.
Мы уже с Вами начали обсуждение работы с JSON в скриптах DaJet Stream... Создайте, пожалуйста, новый issue на GitHub именно по этой задаче - передача массива объектов JSON как табличного параметра в запрос SQL. Я в принципе планировал это сделать. Просто чтобы не забылось =)
Оставьте свое сообщение