athena_aws.sql

select record_schema,
	data_channel,
	record_count
from (
		select 'amdp' as record_schema,
			'AQFERCONVERSIONS' as data_channel,
			sum(cardinality(conversions)) as record_count,
			event_date
		from aqfer.collation_hourly_v5_1
		group by event_date
		union
		select 'amdp' as record_schema,
			'AQFERGEOEVENTS' as data_channel,
			sum(cardinality(geo_events)) as record_count,
			event_date
		from aqfer.collation_hourly_v5_1
		group by event_date
		union
		select 'amdp' as record_schema,
			'AQFERVIEWS' as data_channel,
			count(view) as record_count,
			event_date
		from aqfer.collation_hourly_v5_1
			cross join unnest("collation_hourly_v5_1".views) as t(view)
		where view.has_interaction = False
		group by event_date
		union
		select 'amdp' as record_schema,
			'AQFERINTERACTIONS' as data_channel,
			sum(cardinality(view.interaction)) as record_count,
			event_date
		from aqfer.collation_hourly_v5_1
			cross join unnest("collation_hourly_v5_1".views) as t(view)
		group by event_date
		union
		select 'amdp' as record_schema,
			'AQFERIMPRESSIONS' as data_channel,
			count(imp) as record_count,
			event_date
		from aqfer.collation_hourly_v5_1
			cross join unnest("collation_hourly_v5_1".impressions) as t(imp)
		where imp.has_click = False
			and cardinality(imp.engagements) = 0
		group by event_date
		union
		select 'amdp' as record_schema,
			'AQFERCLICKS' as data_channel,
			sum(cardinality(imp.clicks)) as record_count,
			event_date
		from aqfer.collation_hourly_v5_1
			cross join unnest("collation_hourly_v5_1".impressions) as t(imp)
		group by event_date
		UNION
		select 'amdp' as record_schema,
			'AQFERENGAGEMENTS' as data_channel,
			sum(cardinality(imp.engagements)) as record_count,
			event_date
		from aqfer.collation_hourly_v5_1
			cross join unnest("collation_hourly_v5_1".impressions) as t(imp)
		group by event_date
		union
		select 'amdp' as record_schema,
			'AQFERPOIVISITS' as data_channel,
			sum(cardinality(poi_visits)) as record_count,
			event_date
		from aqfer.collation_hourly_v5_1
		group by event_date
		union
		select 'amdp' as record_schema,
			'AQFEROTHEREVENTS' as data_channel,
			sum(cardinality(other_event)) as record_count,
			event_date
		from aqfer.collation_hourly_v5_1
		group by event_date
		union
          select 'amdp' as record_schema,
            'AQFERIDSYNCS' as data_channel,
            sum(cardinality(id_syncs)) as record_count,
            event_date
          from aqfer.collation_hourly_v5_1
          group by event_date
        union
          select 'amdp' as record_schema,
            'AQFERTEXTCLICKS' as data_channel,
            sum(cardinality(text_clicks)) as record_count,
            event_date
          from aqfer.collation_hourly_v5_1
          group by event_date

	)
where record_count > 0
	and event_date = '{{env "PREV_DATE"}}';
  • Table of contents

Was this article helpful?