shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: fix ingest session store to redis

Browse Source
This commit is contained in:
lingniu
2026-07-01 14:47:12 +08:00
parent aa30a413c5
commit 3795e43a6a
4 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
modules/apps/gb32960-ingest-app/src/main/resources/application.yml
View File

@@ -88,7 +88,7 @@ lingniu:
rate-limit: rate-limit:
per-vin-qps: 50 per-vin-qps: 50
session: session:
store: ${SESSION_STORE:redis} store: redis
ttl: ${SESSION_TTL:30m} ttl: ${SESSION_TTL:30m}
identity: identity:
store: ${VEHICLE_IDENTITY_STORE:mysql} store: ${VEHICLE_IDENTITY_STORE:mysql}

5
modules/apps/gb32960-ingest-app/src/test/java/com/lingniu/ingest/gb32960app/Gb32960IngestAppDefaultsTest.java
View File

@@ -46,7 +46,7 @@ class Gb32960IngestAppDefaultsTest {
.containsEntry("lingniu.ingest.sink.kafka.consumer.enabled", false) .containsEntry("lingniu.ingest.sink.kafka.consumer.enabled", false)
.containsEntry("lingniu.ingest.sink.archive.enabled", "${SINK_ARCHIVE_ENABLED:true}") .containsEntry("lingniu.ingest.sink.archive.enabled", "${SINK_ARCHIVE_ENABLED:true}")
.containsEntry("lingniu.ingest.sink.archive.path", "${SINK_ARCHIVE_PATH:./archive/}") .containsEntry("lingniu.ingest.sink.archive.path", "${SINK_ARCHIVE_PATH:./archive/}")
.containsEntry("lingniu.ingest.session.store", "${SESSION_STORE:redis}") .containsEntry("lingniu.ingest.session.store", "redis")
.containsEntry("lingniu.ingest.identity.store", "${VEHICLE_IDENTITY_STORE:mysql}") .containsEntry("lingniu.ingest.identity.store", "${VEHICLE_IDENTITY_STORE:mysql}")
.containsEntry("lingniu.ingest.identity.mysql.table-name", .containsEntry("lingniu.ingest.identity.mysql.table-name",
"${VEHICLE_IDENTITY_MYSQL_TABLE:vehicle_identity_bindings}") "${VEHICLE_IDENTITY_MYSQL_TABLE:vehicle_identity_bindings}")
@@ -67,7 +67,8 @@ class Gb32960IngestAppDefaultsTest {
.doesNotContain("vehicle-stat:"); .doesNotContain("vehicle-stat:");
assertThat(applicationYaml()) assertThat(applicationYaml())
.contains("password: ${GB32960_PLATFORM_PWD_HYUNDAI:}") .contains("password: ${GB32960_PLATFORM_PWD_HYUNDAI:}")
.contains("password: ${GB32960_PLATFORM_PWD_YUEJIN:}"); .contains("password: ${GB32960_PLATFORM_PWD_YUEJIN:}")
.doesNotContain("SESSION_STORE");
} }
private static Properties applicationProperties() { private static Properties applicationProperties() {

2
modules/apps/jt808-ingest-app/src/main/resources/application.yml
View File

@@ -52,7 +52,7 @@ lingniu:
rate-limit: rate-limit:
per-vin-qps: 50 per-vin-qps: 50
session: session:
store: ${SESSION_STORE:redis} store: redis
ttl: ${SESSION_TTL:30m} ttl: ${SESSION_TTL:30m}
identity: identity:
store: ${VEHICLE_IDENTITY_STORE:mysql} store: ${VEHICLE_IDENTITY_STORE:mysql}

5
modules/apps/jt808-ingest-app/src/test/java/com/lingniu/ingest/jt808app/Jt808IngestAppDefaultsTest.java
View File

@@ -33,7 +33,7 @@ class Jt808IngestAppDefaultsTest {
.containsEntry("lingniu.ingest.sink.kafka.topics.realtime", "${KAFKA_TOPIC_JT808_EVENT:vehicle.event.jt808.v1}") .containsEntry("lingniu.ingest.sink.kafka.topics.realtime", "${KAFKA_TOPIC_JT808_EVENT:vehicle.event.jt808.v1}")
.containsEntry("lingniu.ingest.sink.kafka.topics.raw-archive", "${KAFKA_TOPIC_JT808_RAW:vehicle.raw.jt808.v1}") .containsEntry("lingniu.ingest.sink.kafka.topics.raw-archive", "${KAFKA_TOPIC_JT808_RAW:vehicle.raw.jt808.v1}")
.containsEntry("lingniu.ingest.sink.kafka.topics.dlq", "${KAFKA_TOPIC_JT808_DLQ:vehicle.dlq.jt808.v1}") .containsEntry("lingniu.ingest.sink.kafka.topics.dlq", "${KAFKA_TOPIC_JT808_DLQ:vehicle.dlq.jt808.v1}")
.containsEntry("lingniu.ingest.session.store", "${SESSION_STORE:redis}") .containsEntry("lingniu.ingest.session.store", "redis")
.containsEntry("lingniu.ingest.identity.store", "${VEHICLE_IDENTITY_STORE:mysql}") .containsEntry("lingniu.ingest.identity.store", "${VEHICLE_IDENTITY_STORE:mysql}")
.containsEntry("lingniu.ingest.identity.mysql.table-name", .containsEntry("lingniu.ingest.identity.mysql.table-name",
"${VEHICLE_IDENTITY_MYSQL_TABLE:vehicle_identity_bindings}") "${VEHICLE_IDENTITY_MYSQL_TABLE:vehicle_identity_bindings}")
@@ -54,7 +54,8 @@ class Jt808IngestAppDefaultsTest {
.doesNotContain("event-history:") .doesNotContain("event-history:")
.doesNotContain("event-file-store:") .doesNotContain("event-file-store:")
.doesNotContain("vehicle-state:") .doesNotContain("vehicle-state:")
.doesNotContain("vehicle-stat:"); .doesNotContain("vehicle-stat:")
.doesNotContain("SESSION_STORE");
} }
private static Properties applicationProperties() { private static Properties applicationProperties() {