Большинство ожидаемых продаж интеграции предприятия между Salesforce и внешними аналитическими платформами зависят от настраиваемого кода. Они работают, пока что-то не сломается. Ошибка схемы, исчерпание API и пробелы безвозвратного удаления требуют постоянного инженерного вмешательства. По мере перехода компаний к гибкой архитектуре с поддержкой разработчиков эта модель становится узким местом: аналитические группы ждут инженерных спринтов для добавления поля Salesforce в схему в нисходящем направлении, неудачные ночные загрузки задерживают утреннюю отчетность в понедельник, а простые изменения конфигурации требуют проверки кода и развертывания.

CRM Analytics, нативная платформа аналитики и бизнес-аналитики Salesforce, решает эту проблему, позволяя компаниям изучать данные, создавать интерактивные панели мониторинга и открывать важные данные на основе искусственного интеллекта, не покидая экосистемы Salesforce. Центральное место в этой возможности занимает декларативная функция синхронизации данных с низким кодом, встроенная в платформу: CRM Analytics SyncOut и CRM Analytics SyncIn.

CRM Analytics SyncOut перемещает записи Salesforce во внешние хранилища данных по настроенному расписанию, используя сбор данных об изменении (CDC) для дополнительных загрузок и встроенное отслеживание безвозвратного удаления для обозначения необратимо удаленных записей. CRM Analytics SyncIn возвращает внешние данные в Salesforce, соотнося столбцы с полями объектов и вставляя записи посредством Bulk API 2.0. Оба параметра полностью настроены посредством настройки Salesforce. Ни ожидаемых продаж, ни сценариев этапирования, ни настраиваемого мониторинга. Администраторы настраивают задание синхронизации в одном сеансе настройки; платформа автоматически обрабатывает выполнение, повторные попытки, регистрацию ошибок и соотнесение схем.

Это руководство объясняет схему, когда ее использовать, как ее внедрить с помощью Snowflake в качестве отработанного примера и архитектурные рекомендации, определяющие ее соответствие заданной проблеме интеграции.

CRM Analytics — это нативная платформа Salesforce для аналитики и бизнес-аналитики, позволяющая пользователям изучать данные, создавать интерактивные панели мониторинга и находить важные данные на основе искусственного интеллекта в экосистеме Salesforce. Данная платформа перемещает данные между Salesforce и внешними системами посредством двух ключевых возможностей\: CRM Analytics SyncOut и CRM Analytics SyncIn. CRM Analytics SyncOut переносит данные объекта Salesforce на внешнюю платформу данных, поддерживая режимы полной и инкрементной синхронизации (CDC) посредством встроенного отслеживания без возможности удаления. CRM Analytics SyncIn завершает двусторонний цикл, извлекая данные из внешней платформы обратно в объекты Salesforce посредством Bulk API 2.0, обеспечивая надежную и эффективную обработку больших объемов данных.

Примечание к лицензии: CRM Analytics SyncIn и SyncOut недоступны в базовых версиях Salesforce без дополнительной лицензии CRM Analytics. Подтвердите права лицензии перед созданием архитектуры синхронизации, которая зависит от этих возможностей.

Интеграция данных является одной из самых высоких поверхностей трения в архитектуре предприятия. Настраиваемые ожидаемые продажи ETL из Salesforce на аналитическую платформу обычно требуют связанного приложения для проверки подлинности, запланированного задания для извлечения SOQL, слоя трансформации для сверки типов полей, плацдарма для пакетной загрузки и слоя мониторинга для обнаружения сбоев. Каждый компонент настраиваемого кода представляет точку сбоя.

Стоимость этих соединений трения в динамике. Ошибка схемы в Salesforce (переименованное поле, новое значение раскрывающегося списка, измененное имя API) незаметно нарушает ожидаемые продажи. Исчерпание API во время пикового использования тормозит извлечение. Жестко удаленные записи никогда не отображаются в целевой таблице, оставляя устаревшие данные, которые аналитика в дальнейшем обрабатывает как оперативные. Инженерная группа становится препятствием для рутинных операций над данными.

CRM Analytics SyncIn и SyncOut меняют операционную модель. Конфигурация заменяет код. Платформа отвечает за выполнение, обработку ошибок, соотнесение схем и возможность наблюдения. Администраторы могут определять, изменять и отслеживать задания синхронизации, не повышая штраф за разработку.

Результатом этой новой операционной модели является сокращение времени от проектирования интеграции до операционной синхронизации, снижение инженерных расходов и модель интеграции, которая масштабируется в рамках ограничений платформы, а не требует обслуживания настраиваемого кода.

SyncIn и SyncOut - это два режима направленной синхронизации данных CRM Analytics. SyncOut перемещает записи Salesforce на внешнюю платформу. SyncIn добавляет внешние записи в Salesforce. Оба приложения работают в декларативной модели конфигурации без обязательного настраиваемого кода.

Декларативная конфигурация означает, что все алгоритмы синхронизации определяются посредством интерфейса в настройках Salesforce. Исходный объект, целевая таблица, соотнесения полей, расписание синхронизации, режим синхронизации и фильтры устанавливаются посредством метаданных конфигурации. Платформа извлекает план выполнения из этих метаданных и управляет им из конца в конец.

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

Сбор данных об изменении (CDC) - это возможность Salesforce Platform, которая записывает изменения уровня поля объектов в качестве потоков событий. SyncOut использует CDC для обнаружения создания, обновления и удаления без выполнения полного сканирования таблицы. CDC должен быть включен для каждого объекта в настройках Salesforce, прежде чем на него будет ссылаться конфигурация синхронизации.

Безвозвратное отслеживание позволяет решить одну из самых постоянных проблем в Salesforce- to External ETL. Когда запись безвозвратно удаляется в Salesforce, она исчезает из стандартных запросов SOQL. Без четкого отслеживания внешняя платформа не узнает, что запись удалена. При включении функции отслеживания безвозвратного удаления SyncOut помечает удаленные записи в целевой таблице DEL_FLAG = 'Y', предоставляя системам в нисходящем направлении надежный сигнал для фильтрации устаревших данных.

Частота синхронизации настраивается от 15 минут до недели. Выбор - это компромисс между свежестью данных, потреблением API и стоимостью вычисления склада Snowflake. 15-минутные синхронизации подходят к оперативным панелям мониторинга практически в режиме реального времени; ежедневные синхронизации подходят для загруженности пакетных отчетов.

Создание задания синхронизации ограничений регулятора: Ограничение запросов Salesforce API (15 000 вызовов в 24 часа в Unlimited Edition), размер пакета Bulk API 2.0 в 10 000 записей и ограничение строк запросов SOQL в 50 000 на транзакцию — всё это информирует о том, как размер и планирование заданий синхронизации. Платформа обрабатывает фрагменты и пагинацию автоматически, но архитекторы должны учитывать ограниченный головной офис во всех заданиях синхронизации, выполняемых в организации.

Snowflake является основной целью и источником для синхронизации данных с Salesforce CRM Analytics. Он служит конкретным примером работы пакетного и инкрементного перемещения данных от конца к концу.

Данный раздел содержит обзор внедрения CRM Analytics SyncOut и SyncIn с использованием Snowflake в качестве внешней платформы аналитики. Он охватывает каждый метод, общедоступные модели проверки подлинности, инфраструктуры безопасности, ключевые рекомендации платформы и практики наблюдения.

В этой конфигурации SyncOut Salesforce использует CRM Analytics SyncOut для переноса записей в Snowflake. Платформа извлекает данные посредством SOQL, автоматически обрабатывает преобразования типов и загружает их в таблицы Snowflake по настроенному расписанию (от 15 минут до недели). См. текущую документацию Salesforce и Snowflake по определенной семантике загрузки.

В этой конфигурации SyncIn Salesforce использует CRM Analytics SyncIn для извлечения данных обратно в Salesforce. Платформа запрашивает Snowflake посредством API ведомостей и обновляет результаты в Salesforce посредством Bulk API 2.0. Крупные наборы результатов автоматически пагинируются, чтобы не выходить за пределы API. Синхронизация выполняется по настроенному расписанию, от 15 минут до недели.

Синхронизация Salesforce поддерживает несколько методов проверки подлинности для безопасного подключения к Snowflake. Два основных подхода для корпоративных интеграций: «Пара ключей (личный ключ)» и делегированный OAuth 2.0.

Метод 1: Проверка подлинности пары ключей (личный ключ): Проверка подлинности пары ключей - это рекомендованный метод для автоматического перемещения данных между системами, например, CRM Analytics SyncIn и SyncOut. Проверка подлинности основана на веб-маркерах JSON (JWT), а не на паролях или обновляемых маркерах, что делает ее подходящей для незапланированных заданий, не требующих обновления маркера.

• Сертификат Salesforce: Создайте личный ключ и безопасно сохраните его в сертификате Salesforce и управлении ключами.
• Внешние/именованные регистрационные данные: Настройка использования обмена JWT. Salesforce использует сохраненный личный ключ для подписи исходящих запросов на подключение.
• Открытый ключ пользователя Snowflake: Соответствующий открытый ключ назначается напрямую выделенной учетной записи службы Snowflake (например, ALTER USER CRM_ANALYTICS_SYNC_USER SET RSA_PUBLIC_KEY = '...'). Snowflake потом использует этот ключ для проверки входящей подписи JWT. Для этого метода интеграция безопасности не требуется.

Метод 2: Делегированная проверка подлинности OAuth 2.0: Или Salesforce может использовать рукопожатие OAuth для проверки подлинности. Ключевыми компонентами являются:

• Поставщик проверки подлинности: Управление рукопожатием OAuth с Snowflake посредством регистрационных данных клиента, извлеченных из интеграции безопасности Snowflake.
• Внешние регистрационные данные: Безопасно удерживает маркеры OAuth в системе Salesforce и автоматически внедряет их в выноски синхронизации.
• Именованные регистрационные данные: Определяет URL-адрес конечной точки Snowflake (например, https://<account>.snowflakecomputing.com) и ссылается на внешние регистрационные данные.
• Интеграция безопасности Snowflake: Регистрирует Salesforce в качестве надежного клиента OAuth в Snowflake (OAUTH_CLIENT = CUSTOM). Определяет разрешенный URI-адрес переадресации и включает маркеры обновления.

Зависимость конфигурации: Независимо от выбранного метода, эти компоненты образуют цепочку зависимости, соединяющую конфигурацию синхронизации с конечной точкой. Предоставление соответствующим профилям Salesforce доступа к именованным регистрационным данным обязательно; без этого доступа задания синхронизации не выполняются из-за ошибок проверки подлинности, независимо от всех других конфигураций.

Фоновая синхронизация зависит от единого удостоверения интеграции.

• Выделенная организация обслуживания: Создайте специальную учетную запись службы Snowflake с ролью наименьших полномочий, ограниченной только базами данных, схемами и таблицами, обязательными для синхронизации.
• Гранулированные полномочия: В SyncOut эта роль требует INSERT, UPDATE и SELECT в целевых таблицах. Никогда не используйте роли с высокими полномочиями, например, accountADMIN, SECURITYADMIN или SYSADMIN.

• Правительственные ограничения и фрагменты: Во время извлечения SyncOut большие наборы результатов автоматически разделяются на фрагменты для соблюдения контролирующих ограничений Salesforce SOQL. SyncIn извлекает большие наборы результатов из Snowflake Statements API посредством автоматического пагинирования для эффективного управления объемами данных.
• Сбор данных об изменении (CDC): Инкрементный SyncOut зависит от потока событий Salesforce CDC для определения записей, созданных, обновленных или удаленных. Если включено отслеживание безвозвратного удаления, удаленные записи Salesforce не удаляются, но помечаются DEL_FLAG = 'Y' в Snowflake.
• Вставить ограничения: SyncIn использует Bulk API 2.0 для загрузки данных обратно в Salesforce. Для этого необходимо настроить специальное поле «Внешний код» в целевом объекте Salesforce, чтобы оно выступало в качестве ключа обновления и вставки.
• Рекомендации по проектированию: Всегда синхронизируйте из рекомендованных представлений Snowflake, а не из исходных таблиц. Представления позволяют предварительно фильтровать строки, выбирать столбцы и применять бизнес-логику, уменьшая объем данных, продолжительность синхронизации и затраты на вычисления склада Snowflake пропорционально примененной предварительной фильтрации.

Каждый запуск синхронизации создает комплексные контрольные журналы для проверки перемещения данных. Панель мониторинга Sync Job Monitor предоставляет статус в реальном времени, количество обработанных записей, продолжительность выполнения и подробные журналы ошибок для SyncIn и SyncOut. Со стороны Snowflake каждый запрос, отправленный Salesforce, регистрируется в журнале запросов Snowflake, предоставляя полный доступ к задержке выполнения, отсканированным строкам и использованию компьютеров склада. Кроме того, архитекторы определяют специальные контрольные таблицы Snowflake для сбора метаданных выполнения синхронизации — отметки времени, количества записей и ошибок; они не создаются автоматически платформой. Для комплексной проверки сравните количество записей на обеих платформах: проверьте активные записи в Snowflake (WHERE DEL_FLAG = 'N') для запусков SyncOut и сравните учет целевого объекта Salesforce напрямую с исходным представлением Snowflake для запусков SyncIn.

Используйте CRM Analytics SyncIn и SyncOut, если:

• Необходима двусторонняя синхронизация: Данные поступают как в Salesforce посредством SyncIn, так и на внешнюю платформу посредством SyncOut.
• Критически важное значение имеет отслеживание без возможности удаления: Встроенное помечение SyncOut решает исторически сложную проблему ETL без настраиваемой логики сверки.
• Инкрементная синхронизация на основе CDC жизнеспособна: Для массовых объектов Salesforce CDC значительно сокращает потребление API и продолжительность синхронизации по сравнению с полным сканированием.
• Запланированная пакетная синхронизация соответствует требованиям задержки: Минимальная частота синхронизации составляет 15 минут, что позволяет использовать оперативные панели мониторинга и аналитические отчеты в близком к реальному режиме времени.
• Низкие эксплуатационные расходы являются приоритетом: Встроенные панели мониторинга предоставляют полную доступность синхронизации без настраиваемой инфраструктуры регистрации или оповещения, а декларативный пользовательский интерфейс настройки позволяет администраторам определять, изменять и отслеживать задания синхронизации без получения билета на разработку.

Не используйте данную схему, если:

• Требуются сложные трансформации: Многотабличные присоединения, анализ JSON или обработка расширенной бизнес-логики в представлениях Snowflake или выделенном слое трансформации до или после синхронизации.
• Требуется 15-минутная задержка: Для сценариев использования в реальном времени используйте события платформы или Streaming API.
• Очень большие потоковые нагрузки относятся к категории: Объекты с миллионами транзакций в час лучше обслуживаются выделенными потоковыми ожидаемыми продажами (Kafka, события платформы).
• Необходима настраиваемая логика обработки ошибок: Платформа предоставляет стандартные повторы и регистрацию ошибок. Сложные схемы повторных попыток или настраиваемые предупреждения требуют Apex или внешней оркестрации.
• Мультиорганизационная или кросс-облачная синхронизация: CRM Analytics SyncIn и SyncOut работают в одной организации Salesforce. MuleSoft или настраиваемый уровень интеграции обязателен для сценариев с несколькими организациями.

Группа запустила сложные ожидаемые продажи ETL для загрузки данных аналитики Snowflake в наборы данных CRM Analytics. Конвейеры были медленными, хрупкими и требовали постоянного инженерного обслуживания.

CRM Analytics SyncIn был настроен на синхронизацию агрегированных представлений Snowflake напрямую в настраиваемых объектах Salesforce. Группа перенастроила панели мониторинга CRM Analytics на чтение из этих объектов вместо наборов данных CRM Analytics. Результат: два конвейера ETL исключены, продолжительность синхронизации сокращена с четырех часов до 30 минут, а администраторы могут изменять конфигурации синхронизации без получения инженерного билета.

Группа обработки данных должна отслеживать безвозвратно удаленные записи Salesforce в операционном хранилище данных Snowflake. Традиционные подходы требуют разделенных заданий и сложной логики сверки кодов, выполнение которой занимает несколько часов и сопряжено с трудностями при изменении схемы.

Группа настроила CRM Analytics SyncOut с включенным CDC и отслеживанием безвозвратного удаления. Удаленные записи теперь автоматически помечаются флажком DEL_FLAG = 'Y' в таблице потребления Snowflake. Запросы аналитики в нисходящем направлении применяются ГДЕ DEL_FLAG = 'N' для просмотра только активных записей. Логика сверки была полностью исключена, а продолжительность синхронизации упала с восьми часов до 15 минут инкрементных запусков.

Во время приобретения компания-покупатель синхронизировала шесть массовых объектов Salesforce в Snowflake для межорганизационной отчетности и соответствия нормативным требованиям в течение определенного периода времени.

Группа настроила CRM Analytics SyncOut для всех шести объектов с инкрементными синхронизациями на основе CDC. Таблицы метаданных аудита отслеживали изменения схемы и количество записей в периоде интеграции. Они не написали никакого настраиваемого кода. Свежесть данных повысилась с ежедневных до 15-минутных интервалов, а таблицы метаданных аудита обеспечили отслеживаемость, требуемую для отчетности по соблюдению.

Задания синхронизации используют общий бюджет API организации. Организация, выполняющая много заданий высокочастотной синхронизации с большими объектами, рискует исчерпать ограничение 15 000 вызовов API за сутки. Запасите все задания синхронизации, оцените расход API на выполнение и шатайте расписания для распределения нагрузки. В объектах с низким или модерируемым уровнем изменений инкрементный режим на основе CDC может значительно сократить потребление API на выполнение по сравнению с полной синхронизацией.

SyncIn и SyncOut выполняют запросы и загрузки данных на складе Snowflake, потребляя кредиты вычисления. Для простых запросов SELECT обычно достаточно X-Small или Small store. Для больших загрузок SyncOut могут потребоваться средние или большие. Настройте автоматическое приостановление (5 минут бездействия) и автоматическое возобновление на складе. Используйте специальный склад для заданий синхронизации производства, чтобы изолировать расходы и предотвратить споры с запросами пользователей.

Если поле Salesforce переименовано, удалено или изменено API-имя, соответствующее соотнесение полей SyncOut не выполняется или регистрируются ошибки. Установите процесс управления изменениями, включающий проверку активных конфигураций синхронизации как части любого изменения метаданных Salesforce. Аудиторские таблицы Snowflake предоставляют журнал изменений, помогающий определить, когда произошло событие отклонения.

Безвозвратное отслеживание в SyncOut требует включения CDC для объекта Salesforce. Если CDC не включен, параметр «Отслеживание безвозвратных удалений» не действует. Проверьте включение CDC в контрольном списке конфигурации синхронизации, особенно во время первичной настройки или после миграции организации.

Самый распространенный класс сбоя - истечение срока действия регистрационных данных или потеря полномочий. Именованные регистрационные данные должны оставаться действительными, а учетная запись службы Snowflake должна сохранить свои полномочия на использование склада и таблицы. В настройках на основе OAuth сбои обновления маркера могут негласно затормозить синхронизацию заданий. Отслеживайте панель мониторинга отслеживания заданий синхронизации на наличие схем ошибок проверки подлинности и настройте Chatter или электронные уведомления о сбоях заданий.

SyncIn использует поле внешнего кода Salesforce в качестве ключа обновления и вставки. Если исходное представление Snowflake содержит повторяющиеся значения в поле ключа, обновите вставку для задействованных записей. Внедрите уникальность ключевого поля в слое представления Snowflake, прежде чем оно достигнет конфигурации синхронизации.

При сбое синхронизации заданий платформа регистрирует подробные сообщения об ошибках на запись в мониторинге заданий синхронизации. Распространенные сценарии сбоев и их решения:

• Сбой проверки подлинности: проверьте статус именованных регистрационных данных и истечение срока действия организации Snowflake. Повторите проверку подлинности OAuth, если обновление маркера не удалось.
• Ошибка соотнесения полей: проверьте совместимость типов между столбцами Snowflake и полями Salesforce. Просмотрите безопасность поля для текущего пользователя.
• Превышено ограничение по управлению: уменьшить частоту синхронизации или перейти в инкрементный режим CDC для распространения потребления API.
• Склад Snowflake приостановлен: настройте автоматическое возобновление на складе или запустите возобновление вручную до следующей запланированной синхронизации.
• Не работает отслеживание без возможности удаления: подтвердить включение CDC в объекте и установку флажка «Отслеживание безвозвратных удалений» в конфигурации синхронизации.

Синхронизация данных CRM Analytics соответствует нескольким компонентам инфраструктуры Salesforce.

• Надежность (допустимые ошибки): Платформа управляет выполнением, логикой повтора попытки и обработкой частичных сбоев автоматически. Ошибочные записи регистрируются отдельно в мониторинге заданий синхронизации. Внедрите сверку количества записей после сбоев для подтверждения последовательности, дополните уведомлениями о сбое и отслеживайте мониторинг заданий синхронизации на наличие повторяющихся схем ошибок. Инкрементная синхронизация на основе CDC уменьшает радиус взрыва неудачного выполнения, ограничивая область окна данных.
• Trust: Модель регистрационных данных (именованные регистрационные данные, внешние регистрационные данные, поставщик проверки подлинности) применяет зашифрованное хранилище, автоматическое обновление маркера и централизованное управление. Доступ с наименьшими правами на стороне Snowflake ограничивает радиус взрыва скомпрометированных регистрационных данных. Безопасность полей внедряется во время синхронизации; пользователи не могут синхронизировать поля, к которым у них нет доступа.
• Оптимизация ресурсов и затрат: Инкрементный режим CDC является основным рычагом оптимизации производительности. Это уменьшает потребление API, продолжительность синхронизации и стоимость вычисления Snowflake по сравнению с полной синхронизацией. Предварительная фильтрация представления Snowflake еще больше уменьшает объем данных в пути. Автоматическая приостановка склада предотвращает траты на простаивание вычислений.
• Оперативное совершенство: Декларативная модель конфигурации означает, что задания синхронизации определяются в метаданных, а не в коде. Это делает их контролируемыми, воспроизводимыми и управляемыми без участия инженеров. Встроенные панели мониторинга предоставляют полную возможность наблюдения без настраиваемой инфраструктуры регистрации.
• Надежность (масштабируемость): Платформа обрабатывает фрагменты, пагинацию и пакетирование Bulk API автоматически. Для объектов с очень большими рекордными объемами режим инкрементного CDC и внепиковое планирование являются основными архитектурными рычагами для сохранения производительности в пределах контролирующих ограничений.

Данный контрольный список охватывает минимальные шаги по настройке и проверке конфигурации синхронизации.

Контрольный список предварительной настройки:

• Включите «Сбор данных об изменении» для всех объектов Salesforce, предназначенных для инкрементного режима SyncOut (Настройка → Сбор данных об изменении).
• Создайте специализированную учетную запись службы Snowflake с ролью наименьших полномочий; предоставьте только обязательные полномочия таблицы и склада.
• Создайте интеграцию безопасности Snowflake при использовании проверки подлинности OAuth.
• Определите поле «Внешний код» для каждого объекта Salesforce, которое SyncIn будет использовать в качестве ключа обновления и вставки; подтвердите уникальность исходных данных.

Подключение:

• Создание поставщика проверки подлинности в Salesforce (Настройка → Поставщики проверки подлинности).
• Создайте внешние регистрационные данные и свяжитесь с поставщиком проверки подлинности (Настройка → Именованные регистрационные данные → Внешние регистрационные данные).
• Создайте именованные регистрационные данные и свяжите с внешними регистрационными данными (Настройка → Именованные регистрационные данные).
• Предоставьте именованным регистрационным данным доступ к соответствующим профилям Salesforce.

Конфигурация SyncOut:

• Создание подключения Snowflake (Настройка → Analytics Studio → Диспетчер данных → Подключения → Подключения Snowflake).
• Создание конфигурации SyncOut: исходный объект, целевая таблица, режим синхронизации, соотнесения полей, CDC, отслеживание безвозвратного удаления, расписание.
• Начните с ежедневной синхронизации; проверьте качество и производительность данных, прежде чем увеличивать частоту.

Конфигурация SyncIn:

• Создание внешнего источника данных (Настройка → Analytics Studio → Диспетчер данных → Подключения → Подключения Snowflake).
• Создание конфигурации SyncIn: исходное представление, целевой объект, поле «Внешний код», соотнесения полей, расписание.
• Синхронизация из представлений Snowflake, а не из исходных таблиц.

Проверка:

• См. Мониторинг заданий синхронизации после первого выполнения (Настройка → Analytics Studio → Диспетчер данных → Отслеживание заданий синхронизации).
• Запрос контрольной таблицы Snowflake для подтверждения написанных метаданных синхронизации.
• Проверьте безвозвратное удаление пометок, подтвердив наличие и заполнение столбца DEL_FLAG.
• Сравнение количества записей между источником и целью.
• Настройте уведомления о сбое посредством Chatter или электронной почты.

Используйте эту схему, когда запланированная пакетная синхронизация соответствует требованиям задержки, необходим двунаправленный поток данных и уменьшение инженерной зависимости от операций интеграции является приоритетом.

Пример работы Snowflake в этом руководстве иллюстрирует полный жизненный цикл: настройка подключения, конфигурация, поток выполнения и проверка. Те же принципы применяются к любой поддерживаемой внешней платформе данных.

Когда под-15-минутная задержка, сложные трансформации или сценарии с несколькими организациями находятся в области, оцените события платформы, Streaming API или MuleSoft как дополнительные или альтернативные подходы.

Югандхар Бора является архитектором программного обеспечения в Salesforce, специализируется на архитектуре данных в платформе приложений Data & Intelligence. Он руководит инициативами Совета по проверке архитектуры предприятия (EARB), сосредоточенными на управлении данными и объединенных моделях данных, одновременно внося вклад в автоматизированные решения инициализации платформы.