이렇게 인덱스 템플릿을 미리 만들어둘 수 있다.

PUT _index_template/cumulative_access_time
{
  "index_patterns": ["user_cumulative_access_time_*"],
  "priority": 1000,
  "template": {
    "mappings": {
      "properties": {
        "dateRange": { "type": "date_range" }
      }
    }
  }
}

샘플 데이터 삽입

POST user_cumulative_access_time_53856dfbc99b4e4a81bb14a95dc0a60a/_doc/AF0F7130659E4339B571CB133C952C82
{
  "_class" : "com.fm.webinar.domain.user.User",
  "id" : "AF0F7130659E4339B571CB133C952C82",
  "name" : "스트 테",
  "userId" : "11ECE79546BD9A0EA4740247A2F273DE",
  "eventId" : "53856DFBC99B4E4A81BB14A95DC0A60A",
  "sessionId" : "11ECBEF60500E127AA7E02915ECBC9E4",
  "token" : "eyJhbGciOiJIUzI1NiJ9.eyJldmVudElkIjoiNTM4NTZERkJDOTlCNEU0QTgxQkIxNEE5NURDMEE2MEEiLCJyb2xlcyI6WyJST0xFX0JPQVJEX1VTRVIiLCJST0xFX1dFQklOQVJfVVNFUiJdLCJ1c2VyTmFtZSI6IuyKpO2KuCDthYwiLCJzdWIiOiIxMUVDRTc5NTQ2QkQ5QTBFQTQ3NDAyNDdBMkYyNzNERSIsImlhdCI6MTY1NDczOTkzOSwiZXhwIjoxOTU0ODI2MzM5fQ.5o98iU_UKWSwWSlEWwdZxM70KHT42gS8UWNJB70RocI",
  "dateRange" : {
    "gte" : 1660192560648,
    "lte" : 1660192562041
  }
}
POST user_cumulative_access_time_53856dfbc99b4e4a81bb14a95dc0a60a/_doc/2320C9A528C142629EF7B4985456F513
{
  "_class" : "com.fm.webinar.domain.user.User",
  "id" : "2320C9A528C142629EF7B4985456F513",
  "name" : "스트 테",
  "userId" : "11ECE79546BD9A0EA4740247A2F173DE",
  "eventId" : "53856DFBC99B4E4A81BB14A95DC0A60A",
  "sessionId" : "11ECBEF60500E127AA7E02915ECBC9E4",
  "token" : "eyJhbGciOiJIUzI1NiJ9.eyJldmVudElkIjoiNTM4NTZERkJDOTlCNEU0QTgxQkIxNEE5NURDMEE2MEEiLCJyb2xlcyI6WyJST0xFX0JPQVJEX1VTRVIiLCJST0xFX1dFQklOQVJfVVNFUiJdLCJ1c2VyTmFtZSI6IuyKpO2KuCDthYwiLCJzdWIiOiIxMUVDRTc5NTQ2QkQ5QTBFQTQ3NDAyNDdBMkYxNzNERSIsImlhdCI6MTY1NDczOTkzOSwiZXhwIjoxOTU0ODI2MzM5fQ.4uB2zvYlORcNqfIc29xlJr0Pd2juLabrUeeVJ_KNPsQ",
  "dateRange" : {
    "gte" : 1660192563462,
    "lte" : 1660192599087
  }
}
POST user_cumulative_access_time_53856dfbc99b4e4a81bb14a95dc0a60a/_doc/1171DDFF1B434F5EAFFD77FA72A43E2D
{
  "_class" : "com.fm.webinar.domain.user.User",
  "id" : "1171DDFF1B434F5EAFFD77FA72A43E2D",
  "name" : "스트 테",
  "userId" : "11ECE79546BD9A0EA4740247A2F173DE",
  "eventId" : "53856DFBC99B4E4A81BB14A95DC0A60A",
  "sessionId" : "11ECBEF60500E127AA7E02915ECBC9E4",
  "token" : "eyJhbGciOiJIUzI1NiJ9.eyJldmVudElkIjoiNTM4NTZERkJDOTlCNEU0QTgxQkIxNEE5NURDMEE2MEEiLCJyb2xlcyI6WyJST0xFX0JPQVJEX1VTRVIiLCJST0xFX1dFQklOQVJfVVNFUiJdLCJ1c2VyTmFtZSI6IuyKpO2KuCDthYwiLCJzdWIiOiIxMUVDRTc5NTQ2QkQ5QTBFQTQ3NDAyNDdBMkYxNzNERSIsImlhdCI6MTY1NDczOTkzOSwiZXhwIjoxOTU0ODI2MzM5fQ.4uB2zvYlORcNqfIc29xlJr0Pd2juLabrUeeVJ_KNPsQ",
  "dateRange" : {
    "gte" : 1660192613109,
    "lte" : 1660279013109
  }
}
POST user_cumulative_access_time_53856dfbc99b4e4a81bb14a95dc0a60a/_doc/066F909B43D541AA8E4EA3C28C3FB4B2
{
  "_class" : "com.fm.webinar.domain.user.User",
  "id" : "066F909B43D541AA8E4EA3C28C3FB4B2",
  "name" : "스트 테",
  "userId" : "11ECE79546BD9A0EA4740247A2F273DE",
  "eventId" : "53856DFBC99B4E4A81BB14A95DC0A60A",
  "sessionId" : "11ECBEF60500E127AA7E02915ECBC9E4",
  "token" : "eyJhbGciOiJIUzI1NiJ9.eyJldmVudElkIjoiNTM4NTZERkJDOTlCNEU0QTgxQkIxNEE5NURDMEE2MEEiLCJyb2xlcyI6WyJST0xFX0JPQVJEX1VTRVIiLCJST0xFX1dFQklOQVJfVVNFUiJdLCJ1c2VyTmFtZSI6IuyKpO2KuCDthYwiLCJzdWIiOiIxMUVDRTc5NTQ2QkQ5QTBFQTQ3NDAyNDdBMkYyNzNERSIsImlhdCI6MTY1NDczOTkzOSwiZXhwIjoxOTU0ODI2MzM5fQ.5o98iU_UKWSwWSlEWwdZxM70KHT42gS8UWNJB70RocI",
  "dateRange" : {
    "gte" : 1660192562037,
    "lte" : 1660278962037
  }
}

데이터 확인

GET user_cumulative_access_time_53856dfbc99b4e4a81bb14a95dc0a60a/_search

집계 계산하기

GET user_cumulative_access_time_53856dfbc99b4e4a81bb14a95dc0a60a/_search
{
  "size": 0,
  "query": {
    "bool": {
      "must": [
        {
          "term": {
            "sessionId.keyword": "11ECBEF60500E127AA7E02915ECBC9E4"
          }
        }
      ]
    }
  },
  "aggs": {
    "times": {
      "date_histogram": {
        "field": "dateRange",
        "fixed_interval": "10m"
      },
      "aggs": {
        "uniqUser": {
          "cardinality": {
            "field": "userId.keyword"
          }
        }
      }
    }
  }
}

집계 결과

{
  "took": 34,
  "timed_out": false,
  "_shards": {
    "total": 1,
    "successful": 1,
    "skipped": 0,
    "failed": 0
  },
  "hits": {
    "total": {
      "value": 4,
      "relation": "eq"
    },
    "max_score": null,
    "hits": []
  },
  "aggregations": {
    "times": {
      "buckets": [
        {
          "key_as_string": "2022-08-11T04:30:00.000Z",
          "key": 1660192200000,
          "doc_count": 4,
          "uniqUser": {
            "value": 2
          }
        },
        {
          "key_as_string": "2022-08-11T04:40:00.000Z",
          "key": 1660192800000,
          "doc_count": 2,
          "uniqUser": {
            "value": 2
          }
        },
        {
          "key_as_string": "2022-08-11T04:50:00.000Z",
          "key": 1660193400000,
          "doc_count": 2,
          "uniqUser": {
            "value": 2
          }
        },
        {
          "내용": "중략"
        }
      ]
    }
  }
}

사용 모델

@Getter
@Builder(toBuilder = true)
public class User implements Serializable {

    private static final long serialVersionUID = 877386923286039213L;

    @Builder.Default
    private String id = ByteUtil.newId();

    private String name;
    private String userId;
    private String eventId;
    private String sessionId;
    private String token;

    @Builder.Default
    private EsDateRange dateRange = EsDateRange.builder().build();

}

es에서 date_range 형식을 사용하려면 적어도 7.10.2 버전에서는 gte와 lte가 모두 있어야 정상적으로 사용가능하다.

@Getter
@Builder(toBuilder = true)
public class EsDateRange {

    @Builder.Default
    private Timestamp gte = new Timestamp(System.currentTimeMillis());

    // 아마도 24시간 안에 한 번은 클라이언트가 끊길거라 생각하고 24시간을 기본값으로 넣는다.
    @Builder.Default
    private Timestamp lte = new Timestamp(System.currentTimeMillis() + 24 * 60 * 60 * 1000);

}

자바에서 조회시

@Getter
@Builder
public class ParticipantTrend implements Serializable {

    private static final long serialVersionUID = 5445631818801849950L;

    private Timestamp time;
    private int userCount;

}

public List<ParticipantTrend> getParticipantTrend(String eventId, String sessionId) {

    BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery()
            .must(QueryBuilders.termQuery("sessionId.keyword", sessionId));

    DateHistogramAggregationBuilder aggregationUserCount = AggregationBuilders.dateHistogram("times")
            .fixedInterval(DateHistogramInterval.minutes(10))
            .field("dateRange")
            .subAggregation(AggregationBuilders.cardinality("uniqUser").field("userId.keyword"));

    Query searchQuery = new NativeSearchQueryBuilder()
            .withQuery(boolQueryBuilder)
            .addAggregation(aggregationUserCount)
            .withPageable(CustomBlankPage.PAGE)
            .build();

    SearchHits<Object> searchHits = elasticsearchOperations
            .search(searchQuery, Object.class, IndexCoordinates.of(INDEX_USER_CUMULATIVE_ACCESS_TIME_PREFIX + eventId.toLowerCase()));

    ParsedDateHistogram times = searchHits.getAggregations().get("times");
    if (times != null) {
        return times.getBuckets().stream().map(bucket -> {
            ParsedCardinality user = bucket.getAggregations().get("uniqUser");
            return ParticipantTrend.builder()
                    .time(Timestamp.valueOf(((ZonedDateTime) bucket.getKey()).toLocalDateTime()))
                    .userCount((int) user.getValue())
                    .build();
        }).collect(Collectors.toList());
    } else {
        return new ArrayList<>();
    }

}

startDate(startTime)와 endDate(endTime) 사이의 값 집계하기