Connection to multiple Redis Enterprise DB from single application

[rpjtesting]

I have two Redis Enterprise Cluster Databases with 2 different ports, and I need to connect to both databases from single redisom application. Can this be done ?

[bsbodden]

Theoretically yes, but I haven't tested it. I'll try to put a test for this in the next few weeks and add it to the README

[jorgemerinoseera]

I am interested in this kind of feature too because I am trying to make two connections: one for write and one for read. Can you share the status of it please?

I have tried to do it creating different JedisConnectionFactory and RedisTemplate but the application only injects the primary configuration in spite of I am setting the template for the @EnableRedisDocumentRepositories specifically:

@configuration
@EnableRedisDocumentRepositories(
basePackages = {
"com.seera.connectivity.cachemanager.domain.rules.model",
"com.seera.connectivity.cachemanager.domain.HotelSearch.model",
"com.seera.connectivity.cachemanager.repositories.write",
},
redisTemplateRef = "cacheManagerTemplate"
)

Thanks in advance.

[radhakrishna67]

@bsbodden , I have the same problem and situation. I have even created support ticket for the same.
Could you please help us with it?

[bsbodden]

After researching this it seems a bit more complex that it should be... Basically there would have to be a way to bind different Entities/Repository classes to specific connections. There doesn't seem to be anything built-in in Spring Data Redis to make this simple, so we'll work on our own way to do it, but it will probably take at least a month to get a proper implementation.

[nolindnaidoo]

@bsbodden
I too really desire this implementation, it would signifigantly decrease complexity and ops/infrastructure/cost for my use-case.

Reading and write to the same, and also writing to another at the same time. I tried getting creative before I found this GitHub issue.

import { createClient } from 'redis';

// Function to initialize Redis clients for different databases
function devClient(url: string, dbIndex: number) {
  const client = createClient({ url });

  // Select the appropriate database
  client.select(dbIndex, (err) => {
    if (err) {
      console.error(`Error selecting database ${dbIndex}:`, err);
    } else {
      console.log(`Connected to database ${dbIndex}`);
    }
  });

  // Log errors
  client.on('error', (err) => {
    console.error('Redis Client Error', err);
  });

  return client;
}

// Initialize Redis clients for production and development databases
const prodDB = devClient(
  'redis://',
  0 // Database index for production
);

const devDB = devClient(
  'redis://,
  1 // Database index for development
);

export { devDB, prodDB };

import { Repository, Schema } from 'redis-om';

import { devDB, prodDB } from '../redis-client';

const schema = new Schema(
  // intentional snake case exception to ease working with Redis
  'date_url',
  {
    dateURL: { type: 'string' },
  }
);

// Initialize Repository instances for production and development databases
const prod = new Repository(schema, prodDB);
const dev = new Repository(schema, devDB);

export { dev, prod };

// Save to the production database 
await prod.save(date.toLowerCase().trim(), redisData);
await prod.createIndex();

// Save to the development database 
await dev.save(date.toLowerCase().trim(), redisData);
await dev.createIndex();