🍨 🧖🏽 🤶 Azure SQL-End-to-End-Analyse + dbt + Github-Aktionen + Metabasis 🈸 🙍🏾 👩🏼‍🎨

Titel

Hallo Habr! Ich heiße Artemy Kozyr.

In den letzten Jahren habe ich ziemlich umfangreiche Erfahrungen mit Daten und dem, was jetzt als Big Data bezeichnet wird, gesammelt .

Vor nicht allzu langer Zeit ist auch das Interesse an Internet-Marketing und End-to-End-Analytics gestiegen und nicht von Grund auf neu. Mein Freund von der Schauspielagentur versorgte mich mit Daten und Fällen von echten Kunden und hier~~übersprungen~~Weg gehen wir.

Es stellt sich als ziemlich interessant heraus: Azure SQL + dbt + Github-Aktionen + Metabasis.

Die Hälfte des Erfolgs bei der richtigen Aufgabe

Versuchen wir es also ohne Lob und direkt auf den Punkt. Kundenporträt (dies ist das Porträt, für das wir den Service erstellen): der Eigentümer eines Online-Shops / Einzelhandelsnetzwerks / einer mobilen Anwendung / einer Bildungsplattform. Es verfolgt folgende Ziele:

Positionierung und Förderung Ihres Produkts; Geschäftswachstum
Optimierung der Werbekanäle: Konzentrieren Sie sich auf Bereiche, die das beste Ergebnis erzielen
Kontrolle der Ausgaben- und Renditeindikatoren für jeden investierten Rubel
Segmentierung der Benutzer und Aufbau der Kommunikation mit ihnen

Im Durchschnitt nutzt er 4 Gruppen von Diensten:

CRM ( AmoCRM , Bitrix24 ) - Leads, Trichter und Vertrieb; Lebenszyklus und tatsächliche Attribute von Transaktionen
(Yandex.Metrika, Google Analytics) — , , ,
(Facebook, Google Adwords, Yandex.Direct) — , -, ,
Call-tracking/Event tracking — , -

, : , , CRM, . . :

, , . :

()
( !)
( )
( )

()

- . : : ? ( 3:13).

myBI Connect. - , -. , :

( ), , ETL-.

, Facebook (Campaigns), (Adsets) (Ads), , , , , ..

Facebook myBI Connect

2. //

.? .Clickhouse . , , , ( ).

API .

https://api-metrika.yandex.net/stat/v1/data.csv
   ?ids=55254416
   &dimensions=ym:s:date, ym:s:UTMSource, ym:s:UTMMedium, ym:s:UTMCampaign
   &metrics=ym:s:visits, ym:s:ecommercePurchases, ym:s:ecommerceRevenue
   &date1=2020-12-01
   &date2=2020-12-31
   &group=day
   &lang=en
   &accuracy=full
   &sort=ym:s:date
   &limit=100000
   &pretty=true

JSON-, ( cron), (requests), .. .

myBI Connect .

3. Webhook ,

CRM? ?
! Webhook .

. inhouse-CRM, XML:

# get data from XML endpoint with curl utility
curl "https://www.internal-crm.ru/order-list.xml?date-from=01-12-2020&date-to=31-12-2020" -o export.xml

# convert XML to JSON with xq utility
xq . export.xml > export.json

# parse JSON doc with jq utility
jq '[."order-list".date[] | .order[]]' export.json > parsed.json

# post to myBI Connect Webhook endpoint with curl utility
curl --header "Content-Type: application/json" \
 --request POST \
 --data @parsed.json \
 https://app.mybi.ru/webhook/23576/xhsfcxmlyh/

XML, JSON, , myBI Connect Webhook. shell-, .

. 3 (late arriving data)? , .
“ ”.
API.

, . .

(Data Modeling), . , , () - .

DWH: , ,

DWH :

(1) — , , CRM
(2) — (, );
(3) — -, ;

dbt. git-, .sql ( ) .yaml (). dbt : Data Build Tool .

- : BigQuery, Redshift, Snowflake, Postgres, Spark, Presto. Azure SQL Database (managed SQL Server). , ; , -, ( ).

: git- (.sql) (.yaml)

DWH :

: -> -> ->

1. (Sources)

- , myBI Connect. .

2. (Staging)

( views), . :

, UTM-
: , ..
( )

3. (Auxiliary)

Aux . () :

— , , ( )
: , ..

4. (Marts)

— , . , - . . :

, ,
-: ,
: full join,

— ?

— , .

— . , API, , Github Action, .

. . , ().

, , . , . Slack.

— . , . .

,
, , -
(x-ray)

Open Source BI Metabase (!). Amazon Elastic Beanstalk, :

Docker-
Postgres (AWS RDS)
(Load Balancing) -Healthcheck
Metabase

BI Metabase AWS Elastic Beanstalk

? ! , , . , .

, . , .. .

. - — . .

(1) : , , { }, UTM- ( !), , . , , . , .

(2) -. - - php-, .

(3) , . , Google Adwords aud-, kwd-, pla-.

(4) , . !

, .

2. CRM

CRM, , . , , - . , , .

— , CRM-, ?

— : .

? , .

CRM

3. ( )

, , . . : . - :

from costs c
   full join conversions cv on
           c.[] = cv.[]
       and c.[ ] = cv.[ ]
       and c.[  ] = cv.[  ]
       and c.[  ] = cv.[  ]

NULL? ( NULL = NULL).

: , -:

--      
{%- set key_field_list = [
       '[]',
       '[ ]',
       '[  ]',
       '[  ]'
   ]
-%}

--  -     
select

     {{ concat_key(key_field_list) }} as concat_key
   , {{ surrogate_key(key_field_list) }} as hash_key

...

--    :
from costs c
   full join conversions cv on c.hash_key = cv.hash_key

. .

- ;

, full join. , , , : CRM, , ..

-, , ( ). -, .

-, - , . -:

meta_is_row_match (true/false) — ?
meta_row_origin — (././AmoCRM)?

- is_match, row_origin

, CRM - ? . , , . :

   select 
       ...
       , sum(1) as []
       , sum(CASE WHEN [] LIKE '%%' THEN 1 ELSE 0 END) as [ -  ]
       , sum(CASE WHEN [ ] LIKE '%%' THEN 1 ELSE 0 END) as [ -  ]
       , sum(CASE WHEN [ ] LIKE '%%' THEN [] ELSE 0 END) as [ -  ]
       ...

. . , API .. , ym:s:<AttributionModel>UTMSource:

ym:s:lastsignUTMSource --   
ym:s:firstUTMSource --  
ym:s:lastUTMSource --  
ym:s:last_yandex_direct_clickUTMSource --

6. ()

- . , .

Github Action

Github Action kzzzr / mybi-dbt-action — , Docker-, , , , . , , .

. . , , . .

, . — . , . . .

— ? ?

— 1 5 .

— , ?

— .

, TODO:

: , API, Webhook
, dbt CORE . .
+ + + (- -)
( + ),
( ) Github Actions
, , (DAG)
: Git-, DEV PROD.
: , -, .

, . :

— Continuous Integration & Data Tests. , .
(Data Quality): , . , Wheely : : QA .
1- . , http://spasibo-metabase.eu-central-1.elasticbeanstalk.com/
Apache Superset Metabase. , .
- . : , .
self-service BI. . , , , .
: , , .
. . ! .

, ?

pet-project, . :

, . , ?
. Private, public Open Source.
. , - .
. — .

Ich werde Neuigkeiten zu diesem Projekt im Telegrammkanal https://t.me/enthusiastech veröffentlichen .

Bleiben Sie auf dem Laufenden und stellen Sie Fragen. Ich werde diese gerne beantworten.

Danke für die Aufmerksamkeit.

Azure SQL-End-to-End-Analyse + dbt + Github-Aktionen + Metabasis

Die Hälfte des Erfolgs bei der richtigen Aufgabe

()

, ?

More articles: