Usage of more DB's (duplications)

1

Hello,

is it possible to configure more than one DB in the Backend?
If yes (I saw it would work) how woul OpenEMS handle this then?

Right now i implemented a secondary aggregated0 in the Config and the Code writes the data once in the main DB and in the secondary DB duplicationable.

package io.openems.backend.timedata.aggregatedinflux;

import org.osgi.service.metatype.annotations.AttributeDefinition;
import org.osgi.service.metatype.annotations.ObjectClassDefinition;

import io.openems.shared.influxdb.QueryLanguageConfig;

@ObjectClassDefinition(//
		name = "Timedata.AggregatedInfluxDB", //
		description = "Configures the InfluxDB timedata provider" //
)
@interface Config {

	@AttributeDefinition(name = "Component-ID", description = "Unique ID of this Component")
	String id() default "timedata0";

	@AttributeDefinition(name = "Query language", description = "Query language Flux or InfluxQL")
	QueryLanguageConfig queryLanguage() default QueryLanguageConfig.INFLUX_QL;

	@AttributeDefinition(name = "URL", description = "The primary InfluxDB URL, e.g.: http://ip:port")
	String url();

	@AttributeDefinition(name = "Org", description = "The Organisation; '-' for InfluxDB v1")
	String org() default "-";

	@AttributeDefinition(name = "ApiKey", description = "The ApiKey; 'username:password' for InfluxDB v1")
	String apiKey();

	@AttributeDefinition(name = "Bucket", description = "The bucket name; 'database' for InfluxDB v1")
	String bucket();

	@AttributeDefinition(name = "Retention policy name for average values", description = "The retention policy name for InfluxDB v1 for daily values")
	String retentionPolicyAvg() default "rp_avg";

	@AttributeDefinition(name = "Retention policy name for max values", description = "The retention policy name for InfluxDB v1 for monthly values")
	String retentionPolicyMax() default "rp_max";

	@AttributeDefinition(name = "Measurement avg", description = "The InfluxDB measurement for average values")
	String measurementAvg() default "avg";

	@AttributeDefinition(name = "Measurements for max values", description = "Measurements for max values for each timezone. Format: \"(timezone)=(measurement)\"")
	String[] measurementsMax() default { "Europe/Berlin=max" };

	@AttributeDefinition(name = "Read-Only mode", description = "Activates the read-only mode. Then no data is written to InfluxDB.")
	boolean isReadOnly() default false;

	@AttributeDefinition(name = "Number of Threads", description = "Pool-Size: the number of threads dedicated to handle the tasks")
	int poolSize() default 10;

	@AttributeDefinition(name = "Number of max scheduled tasks", description = "Max-Size of Queued tasks.")
	int maxQueueSize() default 5000;

	@AttributeDefinition(name = "Secondary URL", description = "The secondary InfluxDB URL, write-only for security and fallback purposes, e.g.: http://ip:port")
	String secondaryUrl();

	@AttributeDefinition(name = "Secondary Org", description = "The secondary Organisation; '-' for InfluxDB v1")
	String secondaryOrg() default "-";

	@AttributeDefinition(name = "Secondary ApiKey", description = "The secondary ApiKey; 'username:password' for InfluxDB v1")
	String secondaryApiKey();

	@AttributeDefinition(name = "Secondary Bucket", description = "The secondary bucket name; 'database' for InfluxDB v1")
	String secondaryBucket();

	@AttributeDefinition(name = "Secondary InfluxDB Information", description = "Information about the secondary InfluxDB. The secondary database is write-only and serves as a fallback for security reasons in case the primary one fails.")
	String secondaryDbInfo() default "The secondary InfluxDB is write-only and serves as a fallback for security reasons.";

	String webconsole_configurationFactory_nameHint() default "Timedata Aggregated InfluxDB";
}

The code handles it like this then:

		// Initialize the secondary connector if provided in the config
		if (!config.secondaryUrl().isEmpty() && !config.secondaryApiKey().isEmpty()
				&& !config.secondaryBucket().isEmpty()) {
			this.secondaryInfluxConnector = new InfluxConnector(config.id() + "-secondary", config.queryLanguage(),
					URI.create(config.secondaryUrl()), config.secondaryOrg(), config.secondaryApiKey(),
					config.secondaryBucket(), this.oem.getInfluxdbTag(), config.isReadOnly(), config.poolSize(),
					config.maxQueueSize(), throwable -> {
						this.logError(this.log, "Unable to write to secondary InfluxDB. "
								+ throwable.getClass().getSimpleName() + ": " + throwable.getMessage());
					}, true, this.writeParametersAvgPoints, this.writeParametersMaxPoints);
		}

Greetings !