This commit is contained in:
Viet-Tien Ngoc 2024-08-06 11:20:38 +07:00
parent 78d48c7a6a
commit 0c8894a13b

View file

@ -61,7 +61,7 @@ async function clickhouseQuery(data: {
}) { }) {
const { websiteId, sessionId, visitId, eventId, urlPath, eventName, eventData, createdAt } = data; const { websiteId, sessionId, visitId, eventId, urlPath, eventName, eventData, createdAt } = data;
const { getDateFormat, sendMessages, sendMessage } = kafka; const { getDateFormat, sendMessages } = kafka;
const jsonKeys = flattenJSON(eventData); const jsonKeys = flattenJSON(eventData);
@ -101,7 +101,7 @@ async function clickhouseQuery(data: {
message[`double${i + 1}`] = double; message[`double${i + 1}`] = double;
}); });
await sendMessage(message, 'event_data_blob'); // await sendMessage(message, 'event_data_blob');
return data; return data;
} }