fix
This commit is contained in:
parent
b88629abd3
commit
d78e7bfce2
2 changed files with 17 additions and 1 deletions
|
|
@ -64,6 +64,7 @@ export class LogController extends Controller {
|
||||||
"host",
|
"host",
|
||||||
"responseCode",
|
"responseCode",
|
||||||
"output",
|
"output",
|
||||||
|
"userName",
|
||||||
"rootId",
|
"rootId",
|
||||||
].map((v) => ({
|
].map((v) => ({
|
||||||
wildcard: { [`${v}.keyword`]: `*${search}*` },
|
wildcard: { [`${v}.keyword`]: `*${search}*` },
|
||||||
|
|
|
||||||
|
|
@ -52,6 +52,8 @@ export class ReportController extends Controller {
|
||||||
|
|
||||||
const queryData = await elasticsearch.search({
|
const queryData = await elasticsearch.search({
|
||||||
index: ELASTICSEARCH_INDEX,
|
index: ELASTICSEARCH_INDEX,
|
||||||
|
scroll: '1m', // เวลาที่ scroll session จะคงอยู่
|
||||||
|
size: 10000,
|
||||||
query: {
|
query: {
|
||||||
bool: {
|
bool: {
|
||||||
must: [
|
must: [
|
||||||
|
|
@ -68,6 +70,7 @@ export class ReportController extends Controller {
|
||||||
"host",
|
"host",
|
||||||
"responseCode",
|
"responseCode",
|
||||||
"output",
|
"output",
|
||||||
|
"userName",
|
||||||
"rootId",
|
"rootId",
|
||||||
].map((v) => ({
|
].map((v) => ({
|
||||||
wildcard: { [`${v}.keyword`]: `*${search}*` },
|
wildcard: { [`${v}.keyword`]: `*${search}*` },
|
||||||
|
|
@ -118,6 +121,18 @@ export class ReportController extends Controller {
|
||||||
},
|
},
|
||||||
sort: [{ startTimeStamp: sort }],
|
sort: [{ startTimeStamp: sort }],
|
||||||
});
|
});
|
||||||
|
let scrollId = queryData._scroll_id;
|
||||||
|
let results = queryData.hits.hits;
|
||||||
|
|
||||||
|
// ดึงข้อมูลถัดไป
|
||||||
|
const nextBatch = await elasticsearch.scroll({
|
||||||
|
scroll_id: scrollId,
|
||||||
|
scroll: '1m',
|
||||||
|
});
|
||||||
|
|
||||||
|
// เก็บข้อมูลทั้งหมดใน results
|
||||||
|
results = results.concat(nextBatch.hits.hits);
|
||||||
|
|
||||||
interface DocumentSource {
|
interface DocumentSource {
|
||||||
startTimeStamp: Date;
|
startTimeStamp: Date;
|
||||||
userName: string;
|
userName: string;
|
||||||
|
|
@ -128,7 +143,7 @@ export class ReportController extends Controller {
|
||||||
logType: string;
|
logType: string;
|
||||||
responseDescription: string;
|
responseDescription: string;
|
||||||
}
|
}
|
||||||
const raw_data = queryData.hits.hits.map((x) => {
|
const raw_data = results.map((x) => {
|
||||||
const source = x._source as DocumentSource;
|
const source = x._source as DocumentSource;
|
||||||
return {
|
return {
|
||||||
id: x._id,
|
id: x._id,
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue