This commit is contained in:
Mike Cao 2022-09-21 21:59:46 -07:00
commit 0b163274ba
22 changed files with 275 additions and 331 deletions

3
.gitignore vendored
View File

@ -38,3 +38,6 @@ yarn-error.log*
*.dev.yml *.dev.yml
# cert
/lib/cert

View File

@ -15,6 +15,7 @@ import Visitor from 'assets/visitor.svg';
import Eye from 'assets/eye.svg'; import Eye from 'assets/eye.svg';
import { stringToColor } from 'lib/format'; import { stringToColor } from 'lib/format';
import { dateFormat } from 'lib/date'; import { dateFormat } from 'lib/date';
import { safeDecodeURI } from 'next-basics';
import styles from './RealtimeLog.module.css'; import styles from './RealtimeLog.module.css';
const TYPE_ALL = 0; const TYPE_ALL = 0;
@ -113,7 +114,7 @@ export default function RealtimeLog({ data, websites, websiteId }) {
target="_blank" target="_blank"
rel="noreferrer noopener" rel="noreferrer noopener"
> >
{url} {safeDecodeURI(url)}
</a> </a>
); );
} }

View File

@ -1,130 +0,0 @@
SET allow_experimental_object_type = 1;
-- Create Pageview
CREATE TABLE pageview
(
website_id UInt32,
session_uuid UUID,
created_at DateTime('UTC'),
url String,
referrer String
)
engine = MergeTree PRIMARY KEY (session_uuid, created_at)
ORDER BY (session_uuid, created_at)
SETTINGS index_granularity = 8192;
CREATE TABLE pageview_queue (
website_id UInt32,
session_uuid UUID,
created_at DateTime('UTC'),
url String,
referrer String
)
ENGINE = Kafka
SETTINGS kafka_broker_list = 'kafka1:19092,kafka2:19093,kafka3:19094', -- input broker list
kafka_topic_list = 'pageview',
kafka_group_name = 'pageview_consumer_group',
kafka_format = 'JSONEachRow',
kafka_max_block_size = 1048576,
kafka_skip_broken_messages = 1;
CREATE MATERIALIZED VIEW pageview_queue_mv TO pageview AS
SELECT website_id,
session_uuid,
created_at,
url,
referrer
FROM pageview_queue;
-- Create Session
CREATE TABLE session
(
session_uuid UUID,
website_id UInt32,
created_at DateTime('UTC'),
hostname LowCardinality(String),
browser LowCardinality(String),
os LowCardinality(String),
device LowCardinality(String),
screen LowCardinality(String),
language LowCardinality(String),
country LowCardinality(String)
)
engine = MergeTree PRIMARY KEY (session_uuid, created_at)
ORDER BY (session_uuid, created_at)
SETTINGS index_granularity = 8192;
CREATE TABLE session_queue (
session_uuid UUID,
website_id UInt32,
created_at DateTime('UTC'),
hostname LowCardinality(String),
browser LowCardinality(String),
os LowCardinality(String),
device LowCardinality(String),
screen LowCardinality(String),
language LowCardinality(String),
country LowCardinality(String)
)
ENGINE = Kafka
SETTINGS kafka_broker_list = 'kafka1:19092,kafka2:19093,kafka3:19094', -- input broker list
kafka_topic_list = 'session',
kafka_group_name = 'session_consumer_group',
kafka_format = 'JSONEachRow',
kafka_max_block_size = 1048576,
kafka_skip_broken_messages = 1;
CREATE MATERIALIZED VIEW session_queue_mv TO session AS
SELECT session_uuid,
website_id,
created_at,
hostname,
browser,
os,
device,
screen,
language,
country
FROM session_queue;
-- Create event
CREATE TABLE event
(
event_uuid UUID,
website_id UInt32,
session_uuid UUID,
created_at DateTime('UTC'),
url String,
event_name String,
event_data JSON
)
engine = MergeTree PRIMARY KEY (event_uuid, created_at)
ORDER BY (event_uuid, created_at)
SETTINGS index_granularity = 8192;
CREATE TABLE event_queue (
event_uuid UUID,
website_id UInt32,
session_uuid UUID,
created_at DateTime('UTC'),
url String,
event_name String,
event_data String
)
ENGINE = Kafka
SETTINGS kafka_broker_list = 'kafka1:19092,kafka2:19093,kafka3:19094', -- input broker list
kafka_topic_list = 'event',
kafka_group_name = 'event_consumer_group',
kafka_format = 'JSONEachRow',
kafka_max_block_size = 1048576,
kafka_skip_broken_messages = 1;
CREATE MATERIALIZED VIEW event_queue_mv TO event AS
SELECT event_uuid,
website_id,
session_uuid,
created_at,
url,
event_name,
event_data
FROM event_queue;

70
db/clickhouse/schema.sql Normal file
View File

@ -0,0 +1,70 @@
SET allow_experimental_object_type = 1;
-- Create Event
CREATE TABLE event
(
website_id UInt32,
session_uuid UUID,
event_uuid Nullable(UUID),
--session
hostname LowCardinality(String),
browser LowCardinality(String),
os LowCardinality(String),
device LowCardinality(String),
screen LowCardinality(String),
language LowCardinality(String),
country LowCardinality(String),
--pageview
url String,
referrer String,
--event
event_name String,
event_data JSON,
created_at DateTime('UTC')
)
engine = MergeTree
ORDER BY (website_id, session_uuid, created_at)
SETTINGS index_granularity = 8192;
CREATE TABLE event_queue (
website_id UInt32,
session_uuid UUID,
event_uuid Nullable(UUID),
url String,
referrer String,
hostname LowCardinality(String),
browser LowCardinality(String),
os LowCardinality(String),
device LowCardinality(String),
screen LowCardinality(String),
language LowCardinality(String),
country LowCardinality(String),
event_name String,
event_data String,
created_at DateTime('UTC')
)
ENGINE = Kafka
SETTINGS kafka_broker_list = 'domain:9092,domain:9093,domain:9094', -- input broker list
kafka_topic_list = 'event',
kafka_group_name = 'event_consumer_group',
kafka_format = 'JSONEachRow',
kafka_max_block_size = 1048576,
kafka_skip_broken_messages = 1;
CREATE MATERIALIZED VIEW event_queue_mv TO event AS
SELECT website_id,
session_uuid,
event_uuid,
url,
referrer,
hostname,
browser,
os,
device,
screen,
language,
country,
event_name,
event_data,
created_at
FROM event_queue;

View File

@ -62,7 +62,7 @@ function getBetweenDates(field, start_at, end_at) {
and ${getDateFormat(end_at)}`; and ${getDateFormat(end_at)}`;
} }
function getFilterQuery(table, column, filters = {}, params = []) { function getFilterQuery(column, filters = {}, params = []) {
const query = Object.keys(filters).reduce((arr, key) => { const query = Object.keys(filters).reduce((arr, key) => {
const filter = filters[key]; const filter = filters[key];
@ -72,48 +72,28 @@ function getFilterQuery(table, column, filters = {}, params = []) {
switch (key) { switch (key) {
case 'url': case 'url':
if (table === 'pageview' || table === 'event') {
arr.push(`and ${table}.${key}=$${params.length + 1}`);
params.push(decodeURIComponent(filter));
}
break;
case 'os': case 'os':
case 'browser': case 'browser':
case 'device': case 'device':
case 'country': case 'country':
if (table === 'session') {
arr.push(`and ${table}.${key}=$${params.length + 1}`);
params.push(decodeURIComponent(filter));
}
break;
case 'event_name': case 'event_name':
if (table === 'event') { arr.push(`and ${key}=$${params.length + 1}`);
arr.push(`and ${table}.${key}=$${params.length + 1}`);
params.push(decodeURIComponent(filter)); params.push(decodeURIComponent(filter));
}
break; break;
case 'referrer': case 'referrer':
if (table === 'pageview' || table === 'event') { arr.push(`and referrer like $${params.length + 1}`);
arr.push(`and ${table}.referrer like $${params.length + 1}`);
params.push(`%${decodeURIComponent(filter)}%`); params.push(`%${decodeURIComponent(filter)}%`);
}
break; break;
case 'domain': case 'domain':
if (table === 'pageview') { arr.push(`and referrer not like $${params.length + 1}`);
arr.push(`and ${table}.referrer not like $${params.length + 1}`); arr.push(`and referrer not like '/%'`);
arr.push(`and ${table}.referrer not like '/%'`);
params.push(`%://${filter}/%`); params.push(`%://${filter}/%`);
}
break; break;
case 'query': case 'query':
if (table === 'pageview') { arr.push(`and url like '%?%'`);
arr.push(`and ${table}.url like '%?%'`);
}
} }
return arr; return arr;
@ -122,7 +102,7 @@ function getFilterQuery(table, column, filters = {}, params = []) {
return query.join('\n'); return query.join('\n');
} }
function parseFilters(table, column, filters = {}, params = [], sessionKey = 'session_id') { function parseFilters(column, filters = {}, params = []) {
const { domain, url, event_url, referrer, os, browser, device, country, event_name, query } = const { domain, url, event_url, referrer, os, browser, device, country, event_name, query } =
filters; filters;
@ -135,13 +115,9 @@ function parseFilters(table, column, filters = {}, params = [], sessionKey = 'se
sessionFilters, sessionFilters,
eventFilters, eventFilters,
event: { event_name }, event: { event_name },
joinSession: pageviewQuery: getFilterQuery(column, pageviewFilters, params),
os || browser || device || country sessionQuery: getFilterQuery(column, sessionFilters, params),
? `inner join session on ${table}.${sessionKey} = session.${sessionKey}` eventQuery: getFilterQuery(column, eventFilters, params),
: '',
pageviewQuery: getFilterQuery('pageview', column, pageviewFilters, params),
sessionQuery: getFilterQuery('session', column, sessionFilters, params),
eventQuery: getFilterQuery('event', column, eventFilters, params),
}; };
} }

View File

@ -8,11 +8,17 @@ const log = debug('umami:kafka');
function getClient() { function getClient() {
const { username, password } = new URL(process.env.KAFKA_URL); const { username, password } = new URL(process.env.KAFKA_URL);
const brokers = process.env.KAFKA_BROKER.split(','); const brokers = process.env.KAFKA_BROKER.split(',');
const fs = require('fs');
const ssl = const ssl =
username && password username && password
? { ? {
ssl: true, ssl: {
checkServerIdentity: () => undefined,
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: { sasl: {
mechanism: 'plain', mechanism: 'plain',
username, username,
@ -63,7 +69,7 @@ async function sendMessage(params, topic) {
value: JSON.stringify(params), value: JSON.stringify(params),
}, },
], ],
acks: 0, acks: 1,
}); });
} }

View File

@ -4,9 +4,12 @@ import { uuid } from 'lib/crypto';
import redis, { DELETED } from 'lib/redis'; import redis, { DELETED } from 'lib/redis';
import { getClientInfo, getJsonBody } from 'lib/request'; import { getClientInfo, getJsonBody } from 'lib/request';
import { createSession, getSessionByUuid, getWebsiteByUuid } from 'queries'; import { createSession, getSessionByUuid, getWebsiteByUuid } from 'queries';
import clickhouse from 'lib/clickhouse';
export async function getSession(req) { export async function getSession(req) {
const { payload } = getJsonBody(req); const { payload } = getJsonBody(req);
const hasRedis = redis.client;
const hasClickhouse = clickhouse.client;
if (!payload) { if (!payload) {
throw new Error('Invalid request'); throw new Error('Invalid request');
@ -31,11 +34,11 @@ export async function getSession(req) {
let websiteId = null; let websiteId = null;
// Check if website exists // Check if website exists
if (redis.client) { if (hasRedis) {
websiteId = Number(await redis.client.get(`website:${website_uuid}`)); websiteId = Number(await redis.client.get(`website:${website_uuid}`));
} }
// Check database if redis does not have // Check database if does not exists in Redis
if (!websiteId) { if (!websiteId) {
const website = await getWebsiteByUuid(website_uuid); const website = await getWebsiteByUuid(website_uuid);
websiteId = website ? website.website_id : null; websiteId = website ? website.website_id : null;
@ -46,18 +49,18 @@ export async function getSession(req) {
} }
const { userAgent, browser, os, ip, country, device } = await getClientInfo(req, payload); const { userAgent, browser, os, ip, country, device } = await getClientInfo(req, payload);
const session_uuid = uuid(websiteId, hostname, ip, userAgent); const session_uuid = uuid(websiteId, hostname, ip, userAgent);
let sessionId = null; let sessionId = null;
let session = null; let session = null;
if (!hasClickhouse) {
// Check if session exists // Check if session exists
if (redis.client) { if (hasRedis) {
sessionId = Number(await redis.client.get(`session:${session_uuid}`)); sessionId = Number(await redis.client.get(`session:${session_uuid}`));
} }
// Check database if redis does not have // Check database if does not exists in Redis
if (!sessionId) { if (!sessionId) {
session = await getSessionByUuid(session_uuid); session = await getSessionByUuid(session_uuid);
sessionId = session ? session.session_id : null; sessionId = session ? session.session_id : null;
@ -75,18 +78,28 @@ export async function getSession(req) {
country, country,
device, device,
}); });
sessionId = session ? session.session_id : null;
} catch (e) { } catch (e) {
if (!e.message.toLowerCase().includes('unique constraint')) { if (!e.message.toLowerCase().includes('unique constraint')) {
throw e; throw e;
} }
} }
} }
} else {
session = {
session_id: sessionId,
session_uuid,
hostname,
browser,
os,
screen,
language,
country,
device,
};
}
return { return {
website_id: websiteId, website_id: websiteId,
session_id: sessionId, session,
session_uuid,
}; };
} }

View File

@ -59,7 +59,7 @@ export default async (req, res) => {
await useSession(req, res); await useSession(req, res);
const { const {
session: { website_id, session_id, session_uuid }, session: { website_id, session },
} = req; } = req;
const { type, payload } = getJsonBody(req); const { type, payload } = getJsonBody(req);
@ -73,12 +73,11 @@ export default async (req, res) => {
const event_uuid = uuid(); const event_uuid = uuid();
if (type === 'pageview') { if (type === 'pageview') {
await savePageView(website_id, { session_id, session_uuid, url, referrer }); await savePageView(website_id, { session, url, referrer });
} else if (type === 'event') { } else if (type === 'event') {
await saveEvent(website_id, { await saveEvent(website_id, {
session,
event_uuid, event_uuid,
session_id,
session_uuid,
url, url,
event_name, event_name,
event_data, event_data,
@ -87,7 +86,10 @@ export default async (req, res) => {
return badRequest(res); return badRequest(res);
} }
const token = createToken({ website_id, session_id, session_uuid }, secret()); const token = createToken(
{ website_id, session_id: session.session_id, session_uuid: session.session_uuid },
secret(),
);
return send(res, token); return send(res, token);
}; };

View File

@ -48,11 +48,16 @@ export default async (req, res) => {
const endDate = new Date(+end_at); const endDate = new Date(+end_at);
if (sessionColumns.includes(type)) { if (sessionColumns.includes(type)) {
let data = await getSessionMetrics(websiteId, startDate, endDate, type, { let data = await getSessionMetrics(websiteId, {
startDate,
endDate,
field: type,
filters: {
os, os,
browser, browser,
device, device,
country, country,
},
}); });
if (type === 'language') { if (type === 'language') {
@ -101,7 +106,13 @@ export default async (req, res) => {
query: type === 'query' && table !== 'event' ? true : undefined, query: type === 'query' && table !== 'event' ? true : undefined,
}; };
const data = await getPageviewMetrics(websiteId, startDate, endDate, column, table, filters); const data = await getPageviewMetrics(websiteId, {
startDate,
endDate,
column,
table,
filters,
});
return ok(res, data); return ok(res, data);
} }

View File

@ -26,20 +26,34 @@ export default async (req, res) => {
} }
const [pageviews, sessions] = await Promise.all([ const [pageviews, sessions] = await Promise.all([
getPageviewStats(websiteId, startDate, endDate, tz, unit, '*', { getPageviewStats(websiteId, {
startDate,
endDate,
tz,
unit,
count: '*',
filters: {
url, url,
referrer, referrer,
os, os,
browser, browser,
device, device,
country, country,
},
}), }),
getPageviewStats(websiteId, startDate, endDate, tz, unit, 'distinct pageview.', { getPageviewStats(websiteId, {
startDate,
endDate,
tz,
unit,
count: 'distinct pageview.',
filters: {
url, url,
os, os,
browser, browser,
device, device,
country, country,
},
}), }),
]); ]);

View File

@ -29,7 +29,7 @@ function clickhouseQuery(websites, start_at) {
return rawQuery( return rawQuery(
`select `select
event_id, event_uuid,
website_id, website_id,
session_id, session_id,
created_at, created_at,

View File

@ -33,17 +33,19 @@ async function relationalQuery(website_id, { session_id, url, event_name, event_
async function clickhouseQuery( async function clickhouseQuery(
website_id, website_id,
{ event_uuid, session_uuid, url, event_name, event_data }, { session: { country, ...sessionArgs }, event_uuid, url, event_name, event_data },
) { ) {
const { getDateFormat, sendMessage } = kafka; const { getDateFormat, sendMessage } = kafka;
const params = { const params = {
event_uuid, event_uuid,
website_id, website_id,
session_uuid,
created_at: getDateFormat(new Date()), created_at: getDateFormat(new Date()),
url: url?.substring(0, URL_LENGTH), url: url?.substring(0, URL_LENGTH),
event_name: event_name?.substring(0, EVENT_NAME_LENGTH), event_name: event_name?.substring(0, EVENT_NAME_LENGTH),
event_data: JSON.stringify(event_data), event_data: JSON.stringify(event_data),
...sessionArgs,
country: country ? country : null,
}; };
await sendMessage(params, 'event'); await sendMessage(params, 'event');

View File

@ -9,9 +9,9 @@ export async function getPageviewMetrics(...args) {
}); });
} }
async function relationalQuery(website_id, start_at, end_at, column, table, filters = {}) { async function relationalQuery(website_id, { startDate, endDate, column, table, filters = {} }) {
const { rawQuery, parseFilters } = prisma; const { rawQuery, parseFilters } = prisma;
const params = [website_id, start_at, end_at]; const params = [website_id, startDate, endDate];
const { pageviewQuery, sessionQuery, eventQuery, joinSession } = parseFilters( const { pageviewQuery, sessionQuery, eventQuery, joinSession } = parseFilters(
table, table,
column, column,
@ -34,25 +34,19 @@ async function relationalQuery(website_id, start_at, end_at, column, table, filt
); );
} }
async function clickhouseQuery(website_id, start_at, end_at, column, table, filters = {}) { async function clickhouseQuery(website_id, { startDate, endDate, column, filters = {} }) {
const { rawQuery, parseFilters, getBetweenDates } = clickhouse; const { rawQuery, parseFilters, getBetweenDates } = clickhouse;
const params = [website_id]; const params = [website_id];
const { pageviewQuery, sessionQuery, eventQuery, joinSession } = parseFilters( const { pageviewQuery, sessionQuery, eventQuery } = parseFilters(column, filters, params);
table,
column,
filters,
params,
'session_uuid',
);
return rawQuery( return rawQuery(
`select ${column} x, count(*) y `select ${column} x, count(*) y
from ${table} from event
${joinSession} where website_id= $1
where ${table}.website_id= $1 ${column !== 'event_name' ? `and event_name = ''` : ''}
and ${getBetweenDates(table + '.created_at', start_at, end_at)} and ${getBetweenDates('created_at', startDate, endDate)}
${pageviewQuery} ${pageviewQuery}
${joinSession && sessionQuery} ${sessionQuery}
${eventQuery} ${eventQuery}
group by x group by x
order by y desc`, order by y desc`,

View File

@ -11,6 +11,7 @@ export async function getPageviewStats(...args) {
async function relationalQuery( async function relationalQuery(
website_id, website_id,
{
start_at, start_at,
end_at, end_at,
timezone = 'utc', timezone = 'utc',
@ -18,6 +19,7 @@ async function relationalQuery(
count = '*', count = '*',
filters = {}, filters = {},
sessionKey = 'session_id', sessionKey = 'session_id',
},
) { ) {
const { getDateQuery, parseFilters, rawQuery } = prisma; const { getDateQuery, parseFilters, rawQuery } = prisma;
const params = [website_id, start_at, end_at]; const params = [website_id, start_at, end_at];
@ -44,23 +46,11 @@ async function relationalQuery(
async function clickhouseQuery( async function clickhouseQuery(
website_id, website_id,
start_at, { start_at, end_at, timezone = 'UTC', unit = 'day', count = '*', filters = {} },
end_at,
timezone = 'UTC',
unit = 'day',
count = '*',
filters = {},
sessionKey = 'session_uuid',
) { ) {
const { parseFilters, rawQuery, getDateStringQuery, getDateQuery, getBetweenDates } = clickhouse; const { parseFilters, rawQuery, getDateStringQuery, getDateQuery, getBetweenDates } = clickhouse;
const params = [website_id]; const params = [website_id];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters( const { pageviewQuery, sessionQuery } = parseFilters(null, filters, params);
'pageview',
null,
filters,
params,
sessionKey,
);
return rawQuery( return rawQuery(
`select `select
@ -69,11 +59,11 @@ async function clickhouseQuery(
from from
(select (select
${getDateQuery('created_at', unit, timezone)} t, ${getDateQuery('created_at', unit, timezone)} t,
count(${count !== '*' ? `${count}${sessionKey}` : count}) y count(${count !== '*' ? 'session_uuid' : count}) y
from pageview from event
${joinSession} where website_id= $1
where pageview.website_id= $1
and ${getBetweenDates('pageview.created_at', start_at, end_at)} and ${getBetweenDates('created_at', start_at, end_at)}
${pageviewQuery} ${pageviewQuery}
${sessionQuery} ${sessionQuery}
group by t) g group by t) g

View File

@ -27,13 +27,13 @@ async function relationalQuery(websites, start_at) {
async function clickhouseQuery(websites, start_at) { async function clickhouseQuery(websites, start_at) {
return clickhouse.rawQuery( return clickhouse.rawQuery(
`select `select
view_id,
website_id, website_id,
session_id, session_uuid,
created_at, created_at,
url url
from pageview from event
where website_id in (${websites.join[',']} where event_name = ''
and website_id in (${websites.join[',']}
and created_at >= ${clickhouse.getDateFormat(start_at)})`, and created_at >= ${clickhouse.getDateFormat(start_at)})`,
); );
} }

View File

@ -10,7 +10,7 @@ export async function savePageView(...args) {
}); });
} }
async function relationalQuery(website_id, { session_id, url, referrer }) { async function relationalQuery(website_id, { session: { session_id }, url, referrer }) {
return prisma.client.pageview.create({ return prisma.client.pageview.create({
data: { data: {
website_id, website_id,
@ -21,15 +21,19 @@ async function relationalQuery(website_id, { session_id, url, referrer }) {
}); });
} }
async function clickhouseQuery(website_id, { session_uuid, url, referrer }) { async function clickhouseQuery(
website_id,
{ session: { country, ...sessionArgs }, url, referrer },
) {
const { getDateFormat, sendMessage } = kafka; const { getDateFormat, sendMessage } = kafka;
const params = { const params = {
website_id: website_id, website_id: website_id,
session_uuid: session_uuid,
created_at: getDateFormat(new Date()), created_at: getDateFormat(new Date()),
url: url?.substring(0, URL_LENGTH), url: url?.substring(0, URL_LENGTH),
referrer: referrer?.substring(0, URL_LENGTH), referrer: referrer?.substring(0, URL_LENGTH),
...sessionArgs,
country: country ? country : null,
}; };
await sendMessage(params, 'pageview'); await sendMessage(params, 'event');
} }

View File

@ -19,6 +19,14 @@ async function relationalQuery(website_id, data) {
}, },
select: { select: {
session_id: true, session_id: true,
session_uuid: true,
hostname: true,
browser: true,
os: true,
screen: true,
language: true,
country: true,
device: true,
}, },
}) })
.then(async res => { .then(async res => {
@ -35,20 +43,21 @@ async function clickhouseQuery(
{ session_uuid, hostname, browser, os, screen, language, country, device }, { session_uuid, hostname, browser, os, screen, language, country, device },
) { ) {
const { getDateFormat, sendMessage } = kafka; const { getDateFormat, sendMessage } = kafka;
const params = { const params = {
session_uuid: session_uuid, session_uuid,
website_id: website_id, website_id,
created_at: getDateFormat(new Date()), created_at: getDateFormat(new Date()),
hostname: hostname, hostname,
browser: browser, browser,
os: os, os,
device: device, device,
screen: screen, screen,
language: language, language,
country: country ? country : null, country: country ? country : null,
}; };
await sendMessage(params, 'session'); await sendMessage(params, 'event');
if (redis.client) { if (redis.client) {
await redis.client.set(`session:${session_uuid}`, 1); await redis.client.set(`session:${session_uuid}`, 1);

View File

@ -31,7 +31,7 @@ async function clickhouseQuery(session_uuid) {
const params = [session_uuid]; const params = [session_uuid];
return rawQuery( return rawQuery(
`select `select distinct
session_uuid, session_uuid,
website_id, website_id,
created_at, created_at,
@ -42,7 +42,7 @@ async function clickhouseQuery(session_uuid) {
screen, screen,
language, language,
country country
from session from event
where session_uuid = $1`, where session_uuid = $1`,
params, params,
) )

View File

@ -9,15 +9,10 @@ export async function getSessionMetrics(...args) {
}); });
} }
async function relationalQuery(website_id, start_at, end_at, field, filters = {}) { async function relationalQuery(website_id, { startDate, endDate, field, filters = {} }) {
const { parseFilters, rawQuery } = prisma; const { parseFilters, rawQuery } = prisma;
const params = [website_id, start_at, end_at]; const params = [website_id, startDate, endDate];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters( const { pageviewQuery, sessionQuery, joinSession } = parseFilters(null, filters, params);
'pageview',
null,
filters,
params,
);
return rawQuery( return rawQuery(
`select ${field} x, count(*) y `select ${field} x, count(*) y
@ -37,29 +32,19 @@ async function relationalQuery(website_id, start_at, end_at, field, filters = {}
); );
} }
async function clickhouseQuery(website_id, start_at, end_at, field, filters = {}) { async function clickhouseQuery(website_id, { startDate, endDate, field, filters = {} }) {
const { parseFilters, getBetweenDates, rawQuery } = clickhouse; const { parseFilters, getBetweenDates, rawQuery } = clickhouse;
const params = [website_id]; const params = [website_id];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters( const { pageviewQuery, sessionQuery } = parseFilters(null, filters, params);
'pageview',
null,
filters,
params,
'session_uuid',
);
return rawQuery( return rawQuery(
`select ${field} x, count(*) y `select ${field} x, count(*) y
from session as x from event as x
where x.session_uuid in ( where website_id=$1
select pageview.session_uuid and event_name = ''
from pageview and ${getBetweenDates('created_at', startDate, endDate)}
${joinSession}
where pageview.website_id=$1
and ${getBetweenDates('pageview.created_at', start_at, end_at)}
${pageviewQuery} ${pageviewQuery}
${sessionQuery} ${sessionQuery}
)
group by x group by x
order by y desc`, order by y desc`,
params, params,

View File

@ -32,7 +32,7 @@ async function clickhouseQuery(websites, start_at) {
const { rawQuery, getDateFormat } = clickhouse; const { rawQuery, getDateFormat } = clickhouse;
return rawQuery( return rawQuery(
`select `select distinct
session_uuid, session_uuid,
website_id, website_id,
created_at, created_at,
@ -43,7 +43,7 @@ async function clickhouseQuery(websites, start_at) {
screen, screen,
language, language,
country country
from session from event
where ${websites && websites.length > 0 ? `(website_id in (${websites.join[',']})` : '0 = 0'} where ${websites && websites.length > 0 ? `(website_id in (${websites.join[',']})` : '0 = 0'}
and created_at >= ${getDateFormat(start_at)}`, and created_at >= ${getDateFormat(start_at)}`,
); );

View File

@ -29,7 +29,7 @@ async function clickhouseQuery(website_id) {
return rawQuery( return rawQuery(
`select count(distinct session_uuid) x `select count(distinct session_uuid) x
from pageview from event
where website_id = $1 where website_id = $1
and created_at >= ${getDateFormat(subMinutes(new Date(), 5))}`, and created_at >= ${getDateFormat(subMinutes(new Date(), 5))}`,
params, params,

View File

@ -44,13 +44,7 @@ async function relationalQuery(website_id, start_at, end_at, filters = {}) {
async function clickhouseQuery(website_id, start_at, end_at, filters = {}) { async function clickhouseQuery(website_id, start_at, end_at, filters = {}) {
const { rawQuery, getDateQuery, getBetweenDates, parseFilters } = clickhouse; const { rawQuery, getDateQuery, getBetweenDates, parseFilters } = clickhouse;
const params = [website_id]; const params = [website_id];
const { pageviewQuery, sessionQuery, joinSession } = parseFilters( const { pageviewQuery, sessionQuery } = parseFilters(null, filters, params);
'pageview',
null,
filters,
params,
'session_uuid',
);
return rawQuery( return rawQuery(
`select `select
@ -59,18 +53,18 @@ async function clickhouseQuery(website_id, start_at, end_at, filters = {}) {
sum(if(t.c = 1, 1, 0)) as "bounces", sum(if(t.c = 1, 1, 0)) as "bounces",
sum(if(max_time < min_time + interval 1 hour, max_time-min_time, 0)) as "totaltime" sum(if(max_time < min_time + interval 1 hour, max_time-min_time, 0)) as "totaltime"
from ( from (
select pageview.session_uuid, select session_uuid,
${getDateQuery('pageview.created_at', 'day')} time_series, ${getDateQuery('created_at', 'day')} time_series,
count(*) c, count(*) c,
min(created_at) min_time, min(created_at) min_time,
max(created_at) max_time max(created_at) max_time
from pageview from event
${joinSession} where event_name = ''
where pageview.website_id = $1 and website_id = $1
and ${getBetweenDates('pageview.created_at', start_at, end_at)} and ${getBetweenDates('created_at', start_at, end_at)}
${pageviewQuery} ${pageviewQuery}
${sessionQuery} ${sessionQuery}
group by pageview.session_uuid, time_series group by session_uuid, time_series
) t;`, ) t;`,
params, params,
); );