Fixed date value for properties.

This commit is contained in:
Mike Cao 2024-08-20 00:34:01 -07:00
parent 10239fefcd
commit 5aba9acb81
3 changed files with 4 additions and 4 deletions

View File

@ -49,7 +49,7 @@ function getClient() {
return client;
}
function getUTCString(date?: Date) {
function getUTCString(date?: Date | string | number) {
return formatInTimeZone(date || new Date(), 'UTC', 'yyyy-MM-dd HH:mm:ss');
}

View File

@ -60,7 +60,7 @@ async function clickhouseQuery(data: {
}) {
const { websiteId, sessionId, eventId, urlPath, eventName, eventData, createdAt } = data;
const { insert } = clickhouse;
const { insert, getUTCString } = clickhouse;
const { sendMessages } = kafka;
const jsonKeys = flattenJSON(eventData);
@ -76,7 +76,7 @@ async function clickhouseQuery(data: {
data_type: dataType,
string_value: getStringValue(value, dataType),
number_value: dataType === DATA_TYPE.number ? value : null,
date_value: dataType === DATA_TYPE.date ? value?.toISOString() : null,
date_value: dataType === DATA_TYPE.date ? getUTCString(value) : null,
created_at: createdAt,
};
});

View File

@ -94,7 +94,7 @@ async function clickhouseQuery(data: {
data_type: dataType,
string_value: getStringValue(value, dataType),
number_value: dataType === DATA_TYPE.number ? value : null,
date_value: dataType === DATA_TYPE.date ? value?.toISOString() : null,
date_value: dataType === DATA_TYPE.date ? getUTCString(value) : null,
created_at: createdAt,
};
});