fix: migrate to valkey with sentinel
This commit is contained in:
parent
8d93390466
commit
e6507349aa
3 changed files with 125 additions and 35 deletions
|
|
@ -25,30 +25,66 @@ modjo({
|
||||||
redisQueueDedup: {
|
redisQueueDedup: {
|
||||||
pluginName: "ioredis",
|
pluginName: "ioredis",
|
||||||
context: (ctx) => {
|
context: (ctx) => {
|
||||||
|
const redisConfig = {
|
||||||
|
host: process.env.REDIS_QUEUE_DEDUP_HOST,
|
||||||
|
port: process.env.REDIS_QUEUE_DEDUP_PORT || "6379",
|
||||||
|
username: process.env.REDIS_QUEUE_DEDUP_USERNAME || "default",
|
||||||
|
password: process.env.REDIS_QUEUE_DEDUP_PASSWORD,
|
||||||
|
db: process.env.REDIS_QUEUE_DEDUP_DB || "0",
|
||||||
|
}
|
||||||
|
|
||||||
|
// Add Sentinel configuration if provided
|
||||||
|
if (
|
||||||
|
process.env.REDIS_QUEUE_DEDUP_SENTINELS &&
|
||||||
|
process.env.REDIS_QUEUE_DEDUP_SENTINEL_MASTER
|
||||||
|
) {
|
||||||
|
const sentinelEndpoints =
|
||||||
|
process.env.REDIS_QUEUE_DEDUP_SENTINELS.split(",")
|
||||||
|
redisConfig.sentinel = {
|
||||||
|
sentinels: sentinelEndpoints.map((endpoint) => {
|
||||||
|
const [host, port] = endpoint.trim().split(":")
|
||||||
|
return { host, port: parseInt(port, 10) || 26379 }
|
||||||
|
}),
|
||||||
|
name: process.env.REDIS_QUEUE_DEDUP_SENTINEL_MASTER,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
ctx.set("config", {
|
ctx.set("config", {
|
||||||
...ctx.get("config"),
|
...ctx.get("config"),
|
||||||
redis: {
|
redis: redisConfig,
|
||||||
host: process.env.REDIS_QUEUE_DEDUP_HOST,
|
|
||||||
port: process.env.REDIS_QUEUE_DEDUP_PORT || "6379",
|
|
||||||
username: process.env.REDIS_QUEUE_DEDUP_USERNAME || "default",
|
|
||||||
password: process.env.REDIS_QUEUE_DEDUP_PASSWORD,
|
|
||||||
db: process.env.REDIS_QUEUE_DEDUP_DB || "0",
|
|
||||||
},
|
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
redisHotGeodata: {
|
redisHotGeodata: {
|
||||||
pluginName: "ioredis",
|
pluginName: "ioredis",
|
||||||
context: (ctx) => {
|
context: (ctx) => {
|
||||||
|
const redisConfig = {
|
||||||
|
host: process.env.REDIS_HOT_GEODATA_HOST,
|
||||||
|
port: process.env.REDIS_HOT_GEODATA_PORT || "6379",
|
||||||
|
username: process.env.REDIS_HOT_GEODATA_USERNAME || "default",
|
||||||
|
password: process.env.REDIS_HOT_GEODATA_PASSWORD,
|
||||||
|
db: process.env.REDIS_HOT_GEODATA_DB || "0",
|
||||||
|
}
|
||||||
|
|
||||||
|
// Add Sentinel configuration if provided
|
||||||
|
if (
|
||||||
|
process.env.REDIS_HOT_GEODATA_SENTINELS &&
|
||||||
|
process.env.REDIS_HOT_GEODATA_SENTINEL_MASTER
|
||||||
|
) {
|
||||||
|
const sentinelEndpoints =
|
||||||
|
process.env.REDIS_HOT_GEODATA_SENTINELS.split(",")
|
||||||
|
redisConfig.sentinel = {
|
||||||
|
sentinels: sentinelEndpoints.map((endpoint) => {
|
||||||
|
const [host, port] = endpoint.trim().split(":")
|
||||||
|
return { host, port: parseInt(port, 10) || 26379 }
|
||||||
|
}),
|
||||||
|
name: process.env.REDIS_HOT_GEODATA_SENTINEL_MASTER,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
ctx.set("config", {
|
ctx.set("config", {
|
||||||
...ctx.get("config"),
|
...ctx.get("config"),
|
||||||
redis: {
|
redis: redisConfig,
|
||||||
host: process.env.REDIS_HOT_GEODATA_HOST,
|
|
||||||
port: process.env.REDIS_HOT_GEODATA_PORT || "6379",
|
|
||||||
username: process.env.REDIS_HOT_GEODATA_USERNAME || "default",
|
|
||||||
password: process.env.REDIS_HOT_GEODATA_PASSWORD,
|
|
||||||
db: process.env.REDIS_HOT_GEODATA_DB || "0",
|
|
||||||
},
|
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
|
|
||||||
|
|
@ -49,30 +49,66 @@ modjo({
|
||||||
redisHotGeodata: {
|
redisHotGeodata: {
|
||||||
pluginName: "ioredis",
|
pluginName: "ioredis",
|
||||||
context: (ctx) => {
|
context: (ctx) => {
|
||||||
|
const redisConfig = {
|
||||||
|
host: process.env.REDIS_HOT_GEODATA_HOST,
|
||||||
|
port: process.env.REDIS_HOT_GEODATA_PORT || "6379",
|
||||||
|
username: process.env.REDIS_HOT_GEODATA_USERNAME || "default",
|
||||||
|
password: process.env.REDIS_HOT_GEODATA_PASSWORD,
|
||||||
|
db: process.env.REDIS_HOT_GEODATA_DB || "0",
|
||||||
|
}
|
||||||
|
|
||||||
|
// Add Sentinel configuration if provided
|
||||||
|
if (
|
||||||
|
process.env.REDIS_HOT_GEODATA_SENTINELS &&
|
||||||
|
process.env.REDIS_HOT_GEODATA_SENTINEL_MASTER
|
||||||
|
) {
|
||||||
|
const sentinelEndpoints =
|
||||||
|
process.env.REDIS_HOT_GEODATA_SENTINELS.split(",")
|
||||||
|
redisConfig.sentinel = {
|
||||||
|
sentinels: sentinelEndpoints.map((endpoint) => {
|
||||||
|
const [host, port] = endpoint.trim().split(":")
|
||||||
|
return { host, port: parseInt(port, 10) || 26379 }
|
||||||
|
}),
|
||||||
|
name: process.env.REDIS_HOT_GEODATA_SENTINEL_MASTER,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
ctx.set("config", {
|
ctx.set("config", {
|
||||||
...ctx.get("config"),
|
...ctx.get("config"),
|
||||||
redis: {
|
redis: redisConfig,
|
||||||
host: process.env.REDIS_HOT_GEODATA_HOST,
|
|
||||||
port: process.env.REDIS_HOT_GEODATA_PORT || "6379",
|
|
||||||
username: process.env.REDIS_HOT_GEODATA_USERNAME || "default",
|
|
||||||
password: process.env.REDIS_HOT_GEODATA_PASSWORD,
|
|
||||||
db: process.env.REDIS_HOT_GEODATA_DB || "0",
|
|
||||||
},
|
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
redisQueueDedup: {
|
redisQueueDedup: {
|
||||||
pluginName: "ioredis",
|
pluginName: "ioredis",
|
||||||
context: (ctx) => {
|
context: (ctx) => {
|
||||||
|
const redisConfig = {
|
||||||
|
host: process.env.REDIS_QUEUE_DEDUP_HOST,
|
||||||
|
port: process.env.REDIS_QUEUE_DEDUP_PORT || "6379",
|
||||||
|
username: process.env.REDIS_QUEUE_DEDUP_USERNAME || "default",
|
||||||
|
password: process.env.REDIS_QUEUE_DEDUP_PASSWORD,
|
||||||
|
db: process.env.REDIS_QUEUE_DEDUP_DB || "0",
|
||||||
|
}
|
||||||
|
|
||||||
|
// Add Sentinel configuration if provided
|
||||||
|
if (
|
||||||
|
process.env.REDIS_QUEUE_DEDUP_SENTINELS &&
|
||||||
|
process.env.REDIS_QUEUE_DEDUP_SENTINEL_MASTER
|
||||||
|
) {
|
||||||
|
const sentinelEndpoints =
|
||||||
|
process.env.REDIS_QUEUE_DEDUP_SENTINELS.split(",")
|
||||||
|
redisConfig.sentinel = {
|
||||||
|
sentinels: sentinelEndpoints.map((endpoint) => {
|
||||||
|
const [host, port] = endpoint.trim().split(":")
|
||||||
|
return { host, port: parseInt(port, 10) || 26379 }
|
||||||
|
}),
|
||||||
|
name: process.env.REDIS_QUEUE_DEDUP_SENTINEL_MASTER,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
ctx.set("config", {
|
ctx.set("config", {
|
||||||
...ctx.get("config"),
|
...ctx.get("config"),
|
||||||
redis: {
|
redis: redisConfig,
|
||||||
host: process.env.REDIS_QUEUE_DEDUP_HOST,
|
|
||||||
port: process.env.REDIS_QUEUE_DEDUP_PORT || "6379",
|
|
||||||
username: process.env.REDIS_QUEUE_DEDUP_USERNAME || "default",
|
|
||||||
password: process.env.REDIS_QUEUE_DEDUP_PASSWORD,
|
|
||||||
db: process.env.REDIS_QUEUE_DEDUP_DB || "0",
|
|
||||||
},
|
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
|
|
||||||
|
|
@ -27,15 +27,33 @@ modjo({
|
||||||
redisHotGeodata: {
|
redisHotGeodata: {
|
||||||
pluginName: "ioredis",
|
pluginName: "ioredis",
|
||||||
context: (ctx) => {
|
context: (ctx) => {
|
||||||
|
const redisConfig = {
|
||||||
|
host: process.env.REDIS_HOT_GEODATA_HOST,
|
||||||
|
port: process.env.REDIS_HOT_GEODATA_PORT || "6379",
|
||||||
|
username: process.env.REDIS_HOT_GEODATA_USERNAME || "default",
|
||||||
|
password: process.env.REDIS_HOT_GEODATA_PASSWORD,
|
||||||
|
db: process.env.REDIS_HOT_GEODATA_DB || "0",
|
||||||
|
}
|
||||||
|
|
||||||
|
// Add Sentinel configuration if provided
|
||||||
|
if (
|
||||||
|
process.env.REDIS_HOT_GEODATA_SENTINELS &&
|
||||||
|
process.env.REDIS_HOT_GEODATA_SENTINEL_MASTER
|
||||||
|
) {
|
||||||
|
const sentinelEndpoints =
|
||||||
|
process.env.REDIS_HOT_GEODATA_SENTINELS.split(",")
|
||||||
|
redisConfig.sentinel = {
|
||||||
|
sentinels: sentinelEndpoints.map((endpoint) => {
|
||||||
|
const [host, port] = endpoint.trim().split(":")
|
||||||
|
return { host, port: parseInt(port, 10) || 26379 }
|
||||||
|
}),
|
||||||
|
name: process.env.REDIS_HOT_GEODATA_SENTINEL_MASTER,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
ctx.set("config", {
|
ctx.set("config", {
|
||||||
...ctx.get("config"),
|
...ctx.get("config"),
|
||||||
redis: {
|
redis: redisConfig,
|
||||||
host: process.env.REDIS_HOT_GEODATA_HOST,
|
|
||||||
port: process.env.REDIS_HOT_GEODATA_PORT || "6379",
|
|
||||||
username: process.env.REDIS_HOT_GEODATA_USERNAME || "default",
|
|
||||||
password: process.env.REDIS_HOT_GEODATA_PASSWORD,
|
|
||||||
db: process.env.REDIS_HOT_GEODATA_DB || "0",
|
|
||||||
},
|
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue