diff --git a/.gitignore b/.gitignore index 54410324..0bad6264 100644 --- a/.gitignore +++ b/.gitignore @@ -38,3 +38,6 @@ yarn-error.log* *.dev.yml +# cert +/lib/cert + diff --git a/lib/kafka.js b/lib/kafka.js index 732e337f..4ad119ca 100644 --- a/lib/kafka.js +++ b/lib/kafka.js @@ -15,9 +15,9 @@ function getClient() { ? { ssl: { checkServerIdentity: () => undefined, - ca: [fs.readFileSync('./cert/ca_cert.pem', 'utf-8')], - key: fs.readFileSync('./cert/client_key.pem', 'utf-8'), - cert: fs.readFileSync('./cert/client_cert.pem', 'utf-8'), + ca: [fs.readFileSync('./lib/cert/ca_cert.pem', 'utf-8')], + key: fs.readFileSync('./lib/cert/client_key.pem', 'utf-8'), + cert: fs.readFileSync('./lib/cert/client_cert.pem', 'utf-8'), }, sasl: { mechanism: 'plain', diff --git a/queries/analytics/pageview/getPageviews.js b/queries/analytics/pageview/getPageviews.js index 37eaef2d..2bbfff69 100644 --- a/queries/analytics/pageview/getPageviews.js +++ b/queries/analytics/pageview/getPageviews.js @@ -27,9 +27,8 @@ async function relationalQuery(websites, start_at) { async function clickhouseQuery(websites, start_at) { return clickhouse.rawQuery( `select - view_id, website_id, - session_id, + session_uuid, created_at, url from event