[ aws . neptunedata ]
get-sparql-stream
Описание
Получает поток для графа RDF.
С помощью функции Neptune Streams вы можете сгенерировать полную последовательность записей журнала изменений, которые регистрируют каждое изменение данных вашего графа по мере его происхождения. GetSparqlStream позволяет собирать эти записи журнала изменений для графа RDF.
Функция Neptune streams должна быть включена в вашем кластере баз данных Neptune. Чтобы включить потоки, установите параметр кластера баз данных neptune_streams в 1 .
См. Захват изменений графа в реальном времени с помощью потоков Neptune.
При вызове этой операции в кластере Neptune, в котором включена аутентификация IAM, пользователь или роль IAM, производящие запрос, должны иметь прикреплённую политику, разрешающую действие IAM neptune-db:GetStreamRecords в этом кластере.
Обратите внимание, что ключ условия IAM neptune-db:QueryLanguage:Sparql может использоваться в документе политики для ограничения использования запросов SPARQL (см. Доступные ключи условия в политиках доступа к данным IAM Neptune).
См. также: Документация API AWS
Синтаксис
get-sparql-stream
[--limit <value>]
[--iterator-type <value>]
[--commit-num <value>]
[--op-num <value>]
[--encoding <value>]
[--cli-input-json | --cli-input-yaml]
[--generate-cli-skeleton <value>]
[--debug]
[--endpoint-url <value>]
[--no-verify-ssl]
[--no-paginate]
[--output <value>]
[--query <value>]
[--profile <value>]
[--region <value>]
[--version <value>]
[--color <value>]
[--no-sign-request]
[--ca-bundle <value>]
[--cli-read-timeout <value>]
[--cli-connect-timeout <value>]
[--cli-binary-format <value>]
[--no-cli-pager]
[--cli-auto-prompt]
[--no-cli-auto-prompt]
Параметры
--limit (long)
Указывает максимальное количество записей для возврата. Существует также лимит размера ответа в 10 МБ, который нельзя изменить и который имеет приоритет над количеством записей, указанным в параметре limit. Ответ включает запись, нарушающую порог, если был достигнут лимит в 10 МБ.
Диапазон значений для limit составляет от 1 до 100 000 с по умолчанию 10.
--iterator-type (string)
Может быть одним из:
-
AT_SEQUENCE_NUMBER– Указывает, что чтение должно начинаться с номера последовательности событий, указанного совместно параметрамиcommitNumиopNum. -
AFTER_SEQUENCE_NUMBER– Указывает, что чтение должно начинаться сразу после номера последовательности события, указанного совместно параметрамиcommitNumиopNum. -
TRIM_HORIZON– Указывает, что чтение должно начинаться с последней не обрезанной записи в системе, которая является самой старой непросроченной (ещё не удалённой) записью в потоке журнала изменений. -
LATEST– Указывает, что чтение должно начинаться с самой последней записи в системе, которая является самой последней непросроченной (ещё не удалённой) записью в потоке журнала изменений.
Возможные значения:
AT_SEQUENCE_NUMBERAFTER_SEQUENCE_NUMBERTRIM_HORIZONLATEST
--commit-num (long)
iteratorType равно ``AT_SEQUENCE_NUMBER`` или AFTER_SEQUENCE_NUMBER , и игнорируется, когда iteratorType равно TRIM_HORIZON или LATEST .--op-num (long)
1 .--encoding (string)
Если установлено в TRUE, Neptune сжимает ответ с помощью gzip кодирования.
Возможные значения:
gzip
--cli-input-json | --cli-input-yaml (string) Считывает аргументы из предоставленной JSON строки. Строка JSON соответствует формату, предоставленному --generate-cli-skeleton. Если другие аргументы предоставлены в командной строке, эти значения переопределяют значения, предоставленные JSON. Невозможно передавать произвольные двоичные значения с помощью предоставленного значения JSON, так как строка будет интерпретироваться буквально. Это может не быть указано вместе с --cli-input-yaml.
--generate-cli-skeleton (string) Выводит JSON каркас в стандартный вывод без отправки запроса API. Если предоставлено без значения или со значением input, выводит пример входного JSON, который может быть использован как аргумент для --cli-input-json. Аналогично, если предоставлено yaml-input, он выведет пример входного YAML, который может быть использован с --cli-input-yaml. Если предоставлено со значением output, он проверит входные данные команды и вернёт пример выходного JSON для этой команды. Сгенерированный JSON каркас не является стабильным между версиями AWS CLI, и нет гарантий обратной совместимости в сгенерированном JSON каркасе.
Глобальные параметры
--debug (boolean)
Включает отладку логирования.
--endpoint-url (string)
Переопределяет URL по умолчанию команды указанным URL.
--no-verify-ssl (boolean)
По умолчанию AWS CLI использует SSL при общении с сервисами AWS. Для каждого подключения SSL AWS CLI будет проверять сертификаты SSL. Этот параметр переопределяет поведение проверки сертификатов SSL по умолчанию.
--no-paginate (boolean)
Отключает автоматическую постраничную навигацию. Если автоматическая постраничная навигация отключена, AWS CLI выполнит только один вызов для первой страницы результатов.
--output (string)
Стиль форматирования вывода команды.
- json
- text
- table
- yaml
- yaml-stream
--query (string)
Запрос JMESPath для использования при фильтрации данных ответа.
--profile (string)
Использование определенного профиля из файла учетных данных.
--region (string)
Регион для использования. Переопределяет параметры конфигурации/окружения.
--version (string)
Отображение версии этого инструмента.
--color (string)
Включение/выключение цветного вывода.
- on
- off
- auto
--no-sign-request (boolean)
Отказ от подписания запросов. Учетные данные не будут загружены, если этот аргумент предоставлен.
--ca-bundle (string)
Набор сертификатов CA для использования при проверке сертификатов SSL. Переопределяет параметры конфигурации/окружения.
--cli-read-timeout (int)
Максимальное время чтения сокета в секундах. Если значение установлено в 0, чтение сокета будет блокирующим и без таймаута. Значение по умолчанию составляет 60 секунд.
--cli-connect-timeout (int)
Максимальное время подключения сокета в секундах. Если значение установлено в 0, подключение сокета будет блокирующим и без таймаута. Значение по умолчанию составляет 60 секунд.
--cli-binary-format (string)
Стиль форматирования для двоичных блоков. Формат по умолчанию — base64. Формат base64 ожидает, что двоичные блоки будут предоставлены как строка, закодированная в base64. Формат raw-in-base64-out сохраняет совместимость с поведением AWS CLI V1, и двоичные значения должны быть переданы буквально. При предоставлении содержимого из файла, которое соответствует двоичному блоку, fileb:// всегда будет обрабатываться как двоичный и будет использовать содержимое файла напрямую независимо от настройки cli-binary-format. При использовании file:// содержимое файла должно быть правильно отформатировано для настроенного cli-binary-format.
- base64
- raw-in-base64-out
--no-cli-pager (boolean)
Отключение пейджера CLI для вывода.
--cli-auto-prompt (boolean)
Автоматическое запрошенние входных параметров CLI.
--no-cli-auto-prompt (boolean)
Отключение автоматического запроса входных параметров CLI.
Вывод
lastEventId -> (map)
Идентификатор последовательности последнего изменения в ответе потока.
Идентификатор события состоит из двух полей: commitNum, который идентифицирует транзакцию, изменившую граф, и opNum, который идентифицирует конкретную операцию в рамках этой транзакции:
key -> (string)
value -> (string)
lastTrxTimestampInMillis -> (long)
format -> (string)
NQUADS .records -> (list)
Массив сериализованных записей потока журнала изменений, включённых в ответ.
(структура)
Сериализованная запись потока SPARQL, фиксирующая запись журнала изменений для графа RDF.
commitTimestampInMillis -> (long)
eventId -> (map)
Идентификатор последовательности записи изменения потока.
key -> (string)
value -> (string)
data -> (структура)
Сериализованная запись изменения SPARQL. Форматы сериализации каждой записи подробно описаны в Форматы сериализации в потоках Neptune.
stmt -> (string)
op -> (string)
isLastOp -> (boolean)
totalRecords -> (integer)
© Copyright 2025, Amazon Web Services. Created using Sphinx.
|
|