За какой период данные загрузит первый запуск?

На Google BigQuery и ClickHouse пайплайн Leads или Contacts начинает с записей, обновлённых 1 января 2019 года и позже, а пайплайн Events начинает с предыдущего дня. На остальных назначениях каждый запуск перезагружает объект целиком, поэтому уже первый запуск содержит полный список.

Почему отчёт Customers загружает ноль строк?

В аккаунте amoCRM должна быть включена функция покупателей. Пока она выключена, amoCRM не возвращает данные по этому объекту, и запуск завершается с пустой таблицей.

Попадают ли в назначение удалённые сделки и контакты?

Да, если пайплайн работает инкрементально и параметр Created Date At не выбран. Добавьте параметр Is Deleted , чтобы отличать удалённые записи в таблице.

Можно ли выгрузить несколько типов отчётов одним пайплайном?

Нет. Пайплайн выгружает один тип отчёта, поэтому создайте отдельный пайплайн для каждого объекта amoCRM, который нужен в хранилище.

amoCRM

Renta выгружает в ваше хранилище данных семь объектов amoCRM: сделки, контакты, компании, постоянных покупателей, воронки продаж с этапами, пользователей аккаунта и журнал изменений Events, где видно, какой пользователь изменил поле и каким было значение до и после.

Поля каждого объекта вы выбираете сами. Renta загружает их вместе с кастомными полями, тегами и идентификаторами связанных сущностей, а сделки, контакты и события обновляет инкрементально на Google BigQuery и ClickHouse.

Аутентификация

Renta подключается к amoCRM через OAuth. Вы входите в amoCRM, выбираете, какой аккаунт подключить, и разрешаете доступ. Копировать API-ключи из настроек amoCRM не нужно.

Подключение источника amoCRM

Перейдите в каталогStep 1

Откройте раздел Connections > Catalog в левой панели.
Откройте категорию CRM и нажмите на карточку AmoCRM.

Карточка AmoCRM в категории CRM каталога Renta

Начните авторизациюStep 2

Нажмите Log in to your amoCRM account. Renta перенаправит вас на страницу согласия amoCRM.

Страница добавления подключения amoCRM с кнопкой Log in to your amoCRM account

Выдайте доступ в amoCRMStep 3

Если вы управляете несколькими аккаунтами amoCRM, выберите нужный в выпадающем списке аккаунтов.
Нажмите Разрешить.

amoCRM установит виджет Renta в выбранном аккаунте. Отозвать выданный доступ можно в любой момент в настройках интеграции на стороне amoCRM.

Экран согласия amoCRM с выбором аккаунта и кнопкой Разрешить

Назовите подключение и сохранитеStep 4

В поле Source name укажите название источника данных. Оно используется только в интерфейсе Renta.
Нажмите Save.

Карточка Access granted показывает подключённый аккаунт. Кнопка Re-authorize рядом повторяет процедуру OAuth, если позже понадобится сменить аккаунт.

Настройка подключения amoCRM с полем имени источника и кнопкой Save

Источник созданStep 5

Новый источник появится в списке Sources со статусом Active. Теперь его можно использовать в пайплайнах.

Список источников с новым источником amoCRM в статусе Active

Создание пайплайна amoCRM

Когда источник подключён, свяжите его с назначением и настройте пайплайн.

Выберите amoCRM как источникStep 1

В левой панели нажмите New pipeline. На шаге Source выберите AmoCRM в разделе Already connected и нажмите Next step.

Шаг выбора источника с AmoCRM в разделе Already connected

Выберите подключение amoCRMStep 2

Выберите созданное ранее подключение amoCRM и нажмите Next step. На карточке показан субдомен подключённого аккаунта.

Шаг выбора подключения amoCRM с субдоменом аккаунта на карточке подключения

Выберите назначениеStep 3

На шаге Destination выберите назначение (например, Google BigQuery) и нажмите Next step.

Шаг выбора назначения с Google BigQuery в разделе Already connected

Выберите подключение назначенияStep 4

Выберите подключение назначения, в которое нужно загружать данные, и нажмите Next step.

Настройка пайплайна

На последнем шаге выберите отчёт, его поля и расписание.

Тип отчёта

Выберите, какой объект amoCRM выгружает пайплайн. Один пайплайн загружает один тип отчёта.

Настройки пайплайна amoCRM с выпадающим списком Report Types в значении Leads

Тип отчёта	Описание
Leads (сделки)	Записи сделок: бюджет, идентификаторы статуса и воронки, даты создания, обновления и закрытия, причина отказа, кастомные поля, теги и идентификаторы связанных контактов и компаний.
Contacts (контакты)	Записи контактов: полное имя, разложенное на имя и фамилию, кастомные поля, теги и идентификаторы связанных сделок, компаний и покупателей.
Companies (компании)	Записи компаний: атрибуты, кастомные поля, теги и идентификаторы связанных контактов и сделок.
Customers (покупатели)	Записи постоянных покупателей: ожидаемые дата и сумма следующей покупки, LTV, количество покупок, средний чек и периодичность.
Pipelines (воронки)	Воронки продаж аккаунта вместе с их этапами: идентификаторы этапов, названия, порядок и тип.
Users (пользователи)	Пользователи аккаунта: имя, email, язык интерфейса и права доступа к сделкам, контактам, компаниям и задачам.
Events (события)	Журнал изменений аккаунта: сущность, к которой относится событие, тип события, пользователь, который его вызвал, и значение до и после изменения.

Параметры

Выберите поля amoCRM, которые попадут в таблицу назначения.

Выбор параметров amoCRM с вкладками amoCRM fields и Selected и кнопкой Select All

Тип отчёта

Поиск

Название	Имя в API	Описание
ID int	`id`	ID of the company.
Name text	`name`	Name of the company.
Responsible User ID int	`responsible_user_id`	ID of the user responsible for the company.
Group ID int	`group_id`	ID of the group to which the responsible user belongs.
Created By int	`created_by`	ID of the user who created the company.
Updated By int	`updated_by`	ID of the user who last updated the company.
Created At int	`created_at`	Date of creation of the company, passed in Unix Timestamp.
Updated At int	`updated_at`	Date of update of the company, passed in Unix Timestamp.
Closest Task At int	`closest_task_at`	Date of the nearest task to be performed, passed in Unix Timestamp.
Custom fields values structure	`custom_fields_values`	Array of custom fields with additional information.
Tags structure	`tags`	Array of tags with additional information.
Contacts structure	`contacts`	Array of contact with additional information.
Leads structure	`leads`	Array of company additional information.

Название	Имя в API	Описание
ID · Обязательный int	`id`	ID of the contact.
Name text	`name`	Name of the contact.
First Name text	`first_name`	First name of the contact.
Last Name text	`last_name`	Last name of the contact.
Responsible User ID int	`responsible_user_id`	ID of the user responsible for the contact.
Group ID int	`group_id`	ID of the group to which the responsible user belongs.
Created By int	`created_by`	ID of the user who created the contact.
Updated By int	`updated_by`	ID of the user who last updated the contact.
Created At int	`created_at`	Date of creation of the contact, passed in Unix Timestamp.
Created Date At date	`created_date_at`	Creation date of the event, passed in Date format.
Updated At · Обязательный int	`updated_at`	Date of update of the contact, passed in Unix Timestamp.
Is Deleted bool	`is_deleted`	Whether the contact is deleted or not.
Closest Task At int	`closest_task_at`	Date of the nearest task to be performed, passed in Unix Timestamp.
Account ID int	`account_id`	ID of the account in which the contact is located.
Custom fields values structure	`custom_fields_values`	Array of custom fields with additional information.
Tags structure	`tags`	Array of tags with additional information.
Companies structure	`companies`	Array of contact with additional information.
Leads structure	`leads`	Array of company additional information.
Customers structure	`customers`	Array of customers additional information.

Название	Имя в API	Описание
ID · Обязательный int	`id`	ID of the lead.
Name text	`name`	Name of the lead.
Price int	`price`	Budget of the lead.
Responsible User ID int	`responsible_user_id`	ID of the user responsible for the lead.
Group ID int	`group_id`	ID of the group which the responsible user belongs to.
Status ID int	`status_id`	ID of the status the lead is added to, by default – the first stage of the main pipeline.
Pipeline ID int	`pipeline_id`	ID of the pipeline the lead is added to.
Loss Reason ID int	`loss_reason_id`	ID of the reason for lead rejection.
Source ID int	`source_id`	Required GET parameter with. ID of the lead source.
Created By int	`created_by`	ID of the user who created the lead.
Updated By int	`updated_by`	ID of the user who last updated the lead.
Closed At int	`closed_at`	Closure date of the lead, passed in Unix Timestamp.
Created At int	`created_at`	Creation date of the lead, passed in Unix Timestamp.
Created Date At date	`created_date_at`	Creation date of the event, passed in Date format.
Updated At · Обязательный int	`updated_at`	Update date of the lead, passed in Unix Timestamp.
Closest Task At int	`closest_task_at`	Date of the nearest task to be performed, passed in Unix Timestamp.
Is Deleted bool	`is_deleted`	Whether the lead is deleted or not.
Score int	`score`	Scoring of the lead.
Account ID int	`account_id`	ID of the account in which the lead is located.
Labor Cost int	`labor_cost`	Labor cost field type shows how much time was spent working on the lead. Time measured in seconds.
Is Price Modified by Robot bool	`is_price_modified_by_robot`	Required GET parameter with. Whether the lead's budget was last modified by a robot.
Custom fields values structure	`custom_fields_values`	Array of custom fields with additional information.
Tags structure	`tags`	Array of tags with additional information.
Contacts structure	`contacts`	Array of contact with additional information.
Companies structure	`companies`	Array of company additional information.

Название	Имя в API	Описание
ID int	`id`	ID of the pipeline.
Name text	`name`	Name of the pipeline.
Sort int	`sort`	Sort order of the pipeline.
Is Main bool	`is_main`	Whether the pipeline is the main one.
Is Unsorted On bool	`is_unsorted_on`	Whether the unsorted feature is enabled in the pipeline.
Is Archive bool	`is_archive`	Whether the pipeline is archived.
Account ID int	`account_id`	ID of the account in which the pipeline is located.
Statuses structure	`statuses`	Array of custom statuses fields with additional information.

Название	Имя в API	Описание
ID int	`id`	ID of the customer.
Name text	`name`	Name of the customer.
Next Price int	`next_price`	Expected purchase amount.
Next Date int	`next_date`	Expected date of the next purchase. Data in Unix Timestamp.
Responsible User ID int	`responsible_user_id`	ID of the user responsible for the customer.
Status ID int	`status_id`	ID of the customer's status in the account.
Periodicity int	`periodicity`	Periodicity (data required for customers with enabled periodicity functionality).
Created By int	`created_by`	ID of the user who created the customer.
Updated By int	`updated_by`	ID of the user who last updated the customer.
Created At int	`created_at`	Date of creation of the customer, passed in Unix Timestamp.
Updated At int	`updated_at`	Date of update of the customer, passed in Unix Timestamp.
Closest Task At int	`closest_task_at`	Date of the nearest task to be performed, passed in Unix Timestamp.
Is Deleted bool	`is_deleted`	Whether the customer is deleted or not.
LTV int	`ltv`	Total purchase amount.
Purchases Count int	`purchases_count`	Number of purchases.
Average Check int	`average_check`	Average purchase size.
Account ID int	`account_id`	ID of the account in which the customer is located.
Custom fields values structure	`custom_fields_values`	Array of custom fields with additional information.
Tags structure	`tags`	Array of tags with additional information.
Contacts structure	`contacts`	Array of contact with additional information.
Companies structure	`companies`	Array of company additional information.

Название	Имя в API	Описание
ID int	`id`	ID of the user.
Name text	`name`	Full name of the user.
Email text	`email`	Email address of the user.
Language text	`lang`	Language of the user. One of the options: ru, en, es.
Leads Access Rights [Object] structure	`leads`	Object containing user's access rights to leads.
Contacts Access Rights [Object] structure	`contacts`	Object containing user's access rights to contacts.
Companies Access Rights [Object] structure	`companies`	Object containing user's access rights to companies.
Tasks Access Rights [Object] structure	`tasks`	Object containing user's access rights to tasks.
User Rights [Object] structure	`rights`	Object containing user's system-wide rights and permissions.

Название	Имя в API	Описание
ID · Обязательный text	`id`	Unique ID of the event (string format).
Entity ID int	`entity_id`	ID of the entity (lead, contact, company, customer) to which the event is attached.
Entity Type text	`entity_type`	Type of the entity (lead, contact, company, customer).
Type text	`type`	Type of the event (e.g., outgoing_chat_message, custom_field_value_changed, etc.).
Created By int	`created_by`	ID of the user who created the event.
Created At · Обязательный int	`created_at`	Creation date of the event, passed in Unix Timestamp.
Created Date At date	`created_date_at`	Creation date of the event, passed in Date format.
Account ID int	`account_id`	ID of the account in which the event is located.
Responsible User ID int	`responsible_user_id`	ID of the user responsible for the event.
Group ID int	`group_id`	ID of the group to which the responsible user belongs.
Value After json	`value_after`	Array of values after the event change.
Value Before json	`value_before`	Array of values before the event change.

Отмечайте поля по одному или заберите весь набор кнопкой Select All. Текущий выбор виден на вкладке Selected.

В каждом отчёте есть пара полей, без которых пайплайн не работает. В отчётах Leads и Contacts это ID и Updated At, в отчёте Events это ID и Created At. Они выбраны заранее и показаны в списке неактивными.

Структурные параметры загружаются вложенными записями. Custom fields values хранит по одной записи на кастомное поле с его идентификатором, названием, кодом, типом и значением. Так же устроены Tags, Statuses, списки связанных сущностей (Contacts, Companies, Leads, Customers) и объекты с правами доступа в отчёте Users. В отчёте Events поля Value Before и Value After приходят в формате JSON, потому что их структура зависит от типа события.

Параметры с датами, такие как Created At, Updated At, Closed At и Next Date, приходят в формате Unix Timestamp. Created Date At содержит тот же момент, что и Created At, но записанный календарной датой.

Если кастомное поле хранит несколько значений, в колонку field_value попадает первое из них.

Название таблицы

Задайте названия пайплайна и таблицы в назначении.

Поля названия интеграции и названия таблицы amoCRM со списком выбранных параметров выше

Integration name.
Название пайплайна. Используется только в интерфейсе Renta.
Table name.
Название таблицы в назначении. Можно оставить сгенерированное название или ввести своё.

Расписание

Выберите, как часто запускается пайплайн.

Выбор типа расписания amoCRM с отмеченным вариантом Daily

Тип расписания	Описание
Manual	Пайплайн запускается только вручную через интерфейс или по API.
Daily	Пайплайн запускается раз в день в указанное время обновления.
Interval	Пайплайн запускается через заданные интервалы времени.
Cron Expression	Пайплайн запускается по расписанию, заданному cron-выражением.

Для расписания Daily укажите Update time (точное время начала каждого запуска) и нажмите Create pipeline.

Выбор времени обновления и кнопка Create pipeline

Renta также поддерживает запуск по API и интеграцию с внешними оркестраторами, такими как Apache Airflow, Dagster и Prefect. Подробности в документации по расписаниям.

Новый пайплайн появится в разделе Pipelines на вкладке ETL, где видны его запуски, прогресс и название таблицы в назначении.

Список пайплайнов с новой интеграцией amoCRM в статусе Completed

Стратегия синхронизации

Способ синхронизации отчёта amoCRM зависит от типа отчёта и от того, поддерживает ли назначение merge.

Стратегия	Поддерживаемые типы отчётов	Описание
Инкрементальная (merge)	Leads, Contacts, Events (на Google BigQuery и ClickHouse)	Renta запрашивает только записи, изменившиеся с прошлого запуска: Leads и Contacts фильтруются по дате обновления, Events по дате создания. Каждый запуск дополнительно перечитывает трёхдневное перекрытие, поэтому Renta подхватит и то изменение, которое дошло до amoCRM с задержкой. Записи обновляются в назначении по `id`. Для Leads и Contacts Renta дополнительно собирает записи, удалённые в amoCRM за то же окно.
Полная перезагрузка	Companies, Customers, Pipelines, Users (на любом назначении), а также Leads, Contacts, Events (на остальных назначениях)	При каждом запуске Renta загружает полный список записей и заменяет содержимое таблицы в назначении, поэтому таблица отражает состояние аккаунта amoCRM на момент запуска.

Выбранный параметр Created Date At партиционирует таблицу в назначении по дню создания записи. Для отчётов Leads и Contacts он также отключает сбор удалённых записей, и удаления перестают попадать в таблицу.

Renta сама определяет окно синхронизации для каждого типа отчёта, поэтому в пайплайне нет настроек диапазона дат и периода перезаписи.

Часто задаваемые вопросы

Ready to get started?

Build your data pipeline today or get a personalized demo. Start free!

Need help?

Get expert support to ensure your project succeeds. We're here to help!

Feature requests?

Help shape our product! Share your ideas for new features and integrations.