Snowplow로 데이터 파이프라인 구축하기(feat. 쿠버네티스)

d	127.0.0.1
��]�u��UTF-8�ssc-2.6.3-kafka,uMozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.0.0 Safari/537.366http://localhost:3000/@#/com.snowplowanalytics.snowplow/tp2T#{"schema":"iglu:com.snowplowanalytics.snowplow/payload_data/jsonschema/1-0-4","data":[{"e":"pv","url":"http://localhost:3000/","page":"React App","refr":"http://localhost:3000/form","eid":"c71f7c96-597b-4545-be45-ce09649660bd","tv":"js-3.4.0","tna":"ns1","p":"web","cookie":"1","cs":"UTF-8","lang":"ko-KR","res":"2560x1440","cd":"24","dtm":"1659432367557","vp":"306x1304","ds":"306x1304","vid":"4","sid":"b33e46c2-b941-4485-bb99-aa1ed0db449b","duid":"16c0694f-659c-45e7-b1b2-47dbeaa90b40","cx":"eyJzY2hlbWEiOiJpZ2x1OmNvbS5zbm93cGxvd2FuYWx5dGljcy5zbm93cGxvdy9jb250ZXh0cy9qc29uc2NoZW1hLzEtMC0wIiwiZGF0YSI6W3sic2NoZW1hIjoiaWdsdTpjb20uc25vd3Bsb3dhbmFseXRpY3Muc25vd3Bsb3cvd2ViX3BhZ2UvanNvbnNjaGVtYS8xLTAtMCIsImRhdGEiOnsiaWQiOiJkOWFkNGRmOC0xYTViLTQxMDYtYWQzMy01N2JjOTE3OGVmZjMifX1dfQ","stm":"1659432367558"}]}^Timeout-Access: <function1>Host: localhost:9090Connection: keep-aliveMsec-ch-ua: ".Not/A)Brand";v="99", "Google Chrome";v="103", "Chromium";v="103"sec-ch-ua-mobile: ?0�User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.0.0 Safari/537.36sec-ch-ua-platform: "macOS"Accept: */*Origin: http://localhost:3000Sec-Fetch-Site: same-siteSec-Fetch-Mode: corsSec-Fetch-Dest: emptyReferer: http://localhost:3000/"Accept-Encoding: gzip, deflate, br7Accept-Language: ko-KR, ko;q=0.9, en-US;q=0.8, en;q=0.7�Cookie: _sp_ses.1fff=*; sp=23741c49-73a2-4bfb-ac0f-e6658947c969; _sp_id.1fff=16c0694f-659c-45e7-b1b2-47dbeaa90b40.1658819065.4.1659432368.1658915156.b33e46c2-b941-4485-bb99-aa1ed0db449bapplication/jsonhapplication/json�	localhost�$23741c49-73a2-4bfb-ac0f-e6658947c969ziAiglu:com.snowplowanalytics.snowplow/CollectorPayload/thrift/1-0-0

collector {
  interface = "0.0.0.0"
  port = 8080

  streams {
    good = "good"
    bad = "bad"

    sink {
      brokers = "localhost:9092,another.host:9092"
    }
  }
}

namespace java com.snowplowanalytics.snowplow.CollectorPayload.thrift.model1

struct CollectorPayload {
  31337: string schema
  10: optional string querystring
  20: string collector
  30: string encoding
  40: optional string hostname
  50: i64 timestamp
  60: string ipAddress
  70: optional string userAgent
  80: optional string refererUri
  90: optional list<string> headers
  100: optional string networkUserId
  110: string path
  120: optional string contentType
  130: optional string body
}

<!-- Snowplow starts plowing -->
<script type="text/javascript">
;(function(p,l,o,w,i,n,g){if(!p[i]){p.GlobalSnowplowNamespace=p.GlobalSnowplowNamespace||[];
p.GlobalSnowplowNamespace.push(i);p[i]=function(){(p[i].q=p[i].q||[]).push(arguments)
};p[i].q=p[i].q||[];n=l.createElement(o);g=l.getElementsByTagName(o)[0];n.async=1;
n.src=w;g.parentNode.insertBefore(n,g)}}(window,document,"script","{{URL to sp.js}}","snowplow"));

snowplow('newTracker', 'sp', '{{collector_url_here}}', {
    appId: 'my-app-id',
});

snowplow('enableActivityTracking', {
  minimumVisitLength: 30,
  heartbeatDelay: 10
});
snowplow('trackPageView');

</script>
<!-- Snowplow stops plowing -->