Операторы JOIN объединяют источники, сопоставляя общее поле:

• Можно использовать для объединения любых источников: таблиц данных атрибуции и/или пользовательских источников
• Можно использовать для объединения неограниченного числа источников
• Обычно используется для обогащения данных пользовательских источников данными атрибуции

Операторы UNION объединяют таблицы с совпадающей схемой (с одинаковыми столбцами и типами данных):

• Можно использовать для объединения таблиц данных атрибуции или пользовательских источников; нельзя использовать для объединения таблиц данных атрибуции с пользовательскими источниками
• Можно использовать для объединения неограниченного числа источников
• Обычно используется для выполнения запросов к нескольким таблицам данных атрибуции

Данные атрибуции в системе AppsFlyer представлены в 8 разных таблицах:

• Каждая таблица содержит разные типы событий атрибуции.
• Период доступности данных для запросов зависит от таблицы.
  • При создании запроса в консоли Dynamic Query наведите указатель мыши на название таблицы на панели выбора, чтобы увидеть точные даты доступности данных для этой таблицы.
• Таблицы в каждой из перечисленных ниже групп имеют совпадающую схему, поэтому вы можете использовать операторы UNION, чтобы легко выполнять запросы к нескольким таблицам одновременно.

Группа 1: установки приложения и события ретаргетинга

Группа 2: События в приложении

Группа 3: Показы

Этот запрос извлекает информацию о 3 приложениях с наибольшим количеством повторных установок из Snapchat за последние 3 дня.

SELECT app_id, COUNT(*) AS reinstall_count
FROM re_installs
WHERE media_source = 'snapchat_int' AND dt BETWEEN DATE_SUB(current_date(), 3) AND current_date()
GROUP BY app_id
ORDER BY reinstall_count DESC
LIMIT 3;

Чтобы помочь вам оценить целостность данных, этот запрос рассчитывает долю нулевых значений IDFA для 10 медиаисточников с наибольшим количеством установок за последние 7 дней.

SELECT media_source, COUNT(*) AS total_installs, ROUND((SUM(CASE WHEN idfa IS NULL THEN 1 ELSE 0 END) / COUNT(*)) * 100, 2) AS null_idfa_rate
FROM installs
WHERE dt BETWEEN DATE_SUB(current_date(), 3) AND current_date()
GROUP BY media_source
ORDER BY total_installs DESC
LIMIT 10;

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

SELECT media_source,campaign,geo_mean(GREATEST(1, unix_timestamp(install_time, "yyyy-MM-dd HH:mm:ss") - unix_timestamp(attributed_touch_time, "yyyy-MM-dd HH:mm:ss.SSS")))
FROM installs
GROUP BY 1,2

Этот запрос использует данные атрибуции для группировки оценки из Custom Source C (c.score) по медиаисточнику, что позволяет использовать вашу пользовательскую метрику для оценки относительной эффективности различных медиаисточников.

SELECT media_source, sum(c.score)
FROM client_input c JOIN install i on i.appsflyer_id = c.appsflyer_id
GROUP BY media_source;

Этот запрос использует более сложный процесс объединения данных, что позволяет получать расширенные инсайты. Сначала он извлекает и объединяет данные из 2 отдельных таблиц атрибуции ("install" и "installRetarget"). Затем он объединяет эти данные с 2 пользовательскими источниками first-party, чтобы предоставить инсайты о различных типах конверсий, включая агрегированную пользовательскую метрику эффективности (score) и максимальный возраст для каждого типа.

SELECT conversion_type, SUM(sum_score), MAX(max_age)
FROM (SELECT media_source, conversion_type, SUM(score) as sum_score, MAX(age) as max_age
FROM (SELECT * from install union all select * FROM installRetarget) af
JOIN client_input c on c.appsflyer_id = af.appsflyer_id
JOIN client_age ca on ca.appsflyer_id = c.appsflyer_id
GROUP BY media_source, conversion_type)
GROUP BY conversion_type

Каждый из следующих запросов недопустим, поскольку использует данные атрибуции, но не включает оператор GROUP BY:

SELECT *
FROM install;

-----------------------------------------------------

SELECT media_source, appId
FROM client_input c
JOIN install af on af.appsflyer_id = c.appsflyer_id;

Следующий запрос недопустим, поскольку он группирует по недопустимому полю данных атрибуции (appsflyer_id):

SELECT appsflyer_id, count(*)
FROM install
GROUP BY appsflyer_id

-----------------------------------------------------

Следующий запрос недопустим, поскольку он группирует по недопустимому полю данных атрибуции (appsflyer_id). Это недопустимо, даже если поле находится внутри функции:

SELECT substr(appsflyer_id, 0, 5), count(*)
FROM install
GROUP BY substr(appsflyer_id, 0, 5)

-----------------------------------------------------

Следующий запрос недопустим, поскольку он группирует по недопустимому полю данных атрибуции (appsflyer_id). Это недопустимо, даже если поле находится внутри индекса:

SELECT appsflyer_id, count(*)
FROM install
GROUP BY 1

Следующий запрос недопустим, поскольку он группирует по полю пользовательского источника (my_id), которое связано с недопустимым полем данных атрибуции (appsflyer_id); поэтому к my_id применяется то же ограничение на группировку.

SELECT my_id, count(*)
FROM installs
JOIN my_source on my_source.my_id = installs.appsflyer_id
GROUP BY my_id

Следующий запрос недопустим, поскольку в нём предпринимается попытка запустить функцию collect_list для неагрегированных данных атрибуции:

SELECT App_id, collect_list(appsflyer_id)
FROM install
GROUP BY app_id

-----------------------------------------------------

Сравните его со следующим допустимым запросом, который запускает функцию collect_list для агрегированных данных атрибуции:

SELECT app_id, collect_list(campaign)
FROM (select app_id, campaign
  FROM Install
  GROUP BY 1, 2)
GROUP BY app_id

-----------------------------------------------------

Сравните его со следующим допустимым запросом, который запускает функцию collect_list для пользовательских данных источника:

SELECT app_id, collect_list(c.score)
FROM client_input c
GROUP BY app_id