---
metadata:
  - name: generator
    content: Diplodoc Platform v5.50.6
alternate:
  - https://ytsaurus.tech/docs/en/flow/connectors/about.md
  - https://ytsaurus.tech/docs/ru/flow/connectors/about.md
---
> **Documentation Index:** Fetch the complete configuration index at https://ytsaurus.tech/docs/ru/llms.txt

<!-- source: ru/_includes/flow/connectors/about.md -->
# Коннекторы YTsaurus Flow

[Коннектор](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#connector) — компонент, связывающий пайплайн с объектами YTsaurus (очередью, таблицей и т. д.). Каждый коннектор предоставляет [сорс](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#source) для чтения сообщений и/или [синк](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#sink) для записи.

{% note info %}

Используемые пайплайном коннектеры непосредственно влияют на предоставляемые им гарантии обработки сообщений. Перед выбором коннекторов важно ознакомиться с разделом [Гарантии обработки](https://ytsaurus.tech/docs/ru/flow/concepts/guarantees.md).

{% endnote %}

Интеграции с внешними (не-YTsaurus) системами описаны в разделе [Расширения](https://ytsaurus.tech/docs/ru/flow/extensions/about.md).

## Список коннекторов {#list}

#|
|| **Коннектор** | **Есть сорс** | **Есть синк** | **Описание** ||
|| [Queue](https://ytsaurus.tech/docs/ru/flow/connectors/queue.md) | &#10003; | &#10003; |
Чтение и запись в упорядоченную динамическую таблицу с использованием [Queue API](https://ytsaurus.tech/docs/ru/user-guide/dynamic-tables/queues.md) ||
|| [Static Table](https://ytsaurus.tech/docs/ru/flow/connectors/static-table.md) | &#10003; | &#10003; |
Чтение из статических таблиц: фиксированный набор или неограниченная последовательность из директории. Запись непрерывной последовательности статических таблиц в порядке прихода сообщений ||
|| Random | &#10003; | &#65794; |
Чтение случайных данных, генерируемых на лету. Используется для тестов ||
|| [Сервис-лог](https://ytsaurus.tech/docs/ru/flow/connectors/servicelog.md) | &#10003; | &#65794; |
Генерация сервис-лога по внешней таблице [стейтов](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#state). Сервис-лог — это генерация всех ключей из динтаблицы с заданной периодичностью, по сути это способ для переобхода всех стейтов раз в сконфигурированное время ||
|| [Sorted Dynamic Table](https://ytsaurus.tech/docs/ru/flow/connectors/sorted-dynamic-table.md) | &#65794; | &#10003; |
Запись в сортированную динамическую таблицу ||
|#

## Смена источника {#source-change}

Сорс идентифицирует свои [партиции](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#partition) по параметрам, описывающим физический источник; конкретный набор таких параметров указан в документации соответствующего коннектора. Эти параметры входят в ключ партиции, поэтому при их изменении сорс описывает уже другой набор партиций.

При смене источника партиции старого источника исчезают из набора и **завершаются** (`Completing` ⇒ `Completed`): связанный с ними [стейт](https://ytsaurus.tech/docs/ru/flow/concepts/glossary.md#state), включая запомненные оффсеты, удаляется, а не сохраняется в расчёте на возврат той же партиции (как при интеррапте во время репартиционирования). Партиции нового источника создаются с нуля.

{% note warning %}

Параметры, идентифицирующие источник, входят в статический [`Spec`](https://ytsaurus.tech/docs/ru/flow/concepts/spec.md), поэтому менять их можно только на остановленном пайплайне. Новый источник читается независимо от того, что уже было обработано старым: если он содержит те же данные, они будут записаны в выходные потоки повторно.

{% endnote %}
<!-- endsource: ru/_includes/flow/connectors/about.md -->