fix missing columns in getPageview CH. fix Kafka SSL Pathing

pull/1532/head
Francis Cao 2022-09-21 10:51:46 -07:00
parent ad1eea98b1
commit 9c642a6e9e
3 changed files with 7 additions and 5 deletions

3
.gitignore vendored
View File

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

View File

@ -15,9 +15,9 @@ function getClient() {
? { ? {
ssl: { ssl: {
checkServerIdentity: () => undefined, checkServerIdentity: () => undefined,
ca: [fs.readFileSync('./cert/ca_cert.pem', 'utf-8')], ca: [fs.readFileSync('./lib/cert/ca_cert.pem', 'utf-8')],
key: fs.readFileSync('./cert/client_key.pem', 'utf-8'), key: fs.readFileSync('./lib/cert/client_key.pem', 'utf-8'),
cert: fs.readFileSync('./cert/client_cert.pem', 'utf-8'), cert: fs.readFileSync('./lib/cert/client_cert.pem', 'utf-8'),
}, },
sasl: { sasl: {
mechanism: 'plain', mechanism: 'plain',

View File

@ -27,9 +27,8 @@ 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 event from event