Hi Bathiyar, We followed up the above scenario and we could not observe any issues related to Redis "update of insert" process. In Redis implementation, if the given command is "update or insert", we will create a HashSet according to our mapping in Redis side, if it exists, the old one will get updated with the new values. In order to exactly identify the issue could you please share the log output of the "ThresholdTableStream " stream from above execution plan.
Thank You, Anusha On Sat, Nov 24, 2018 at 7:30 PM Mohanadarshan Vivekanandalingam < [email protected]> wrote: > Hi Anusha, > > Can you please followup and respond to this.. > > Thanks, > Mohan > > > On Tue, Nov 20, 2018 at 3:57 PM Bahtiyar KARANLIK < > [email protected]> wrote: > >> Hi All, >> >> I'm trying to retrieve the records in a PostgreSQL table and update or >> insert them into Redis. Below code creates all KEYS in the Redis instance, >> BUT all items contain the very same record (of Threshold rule) (hgetall >> keyname1 and hgetall keyname2 returns the same result) >> >> I'm not sure if this is a bug or a feature, and stuck here.. Any advices >> are highly appreciated.. >> >> best regards, >> >> define trigger ConfigReloadTrigger at every 60 sec; >> >> @Store(type = "rdbms", jdbc.url = "jdbc:postgresql://localhost/my_db", >> username = "my_user", password = "my_pwd" , jdbc.driver.name = >> "org.postgresql.Driver", table.name = 'pm_threshold') >> @Index('metric_name') >> @primaryKey('id') >> define table ThresholdTable(id int, created_at string, updated_at string, >> path_regex string, aggr_field string, aggr_function string, warning double, >> warning_action int, critical double, critical_action int, is_active bool, >> task_step_id int, metric_name string, selectivity int); >> >> @Store(type='redis', table.name='pm_threshold', nodes='localhost:6373', >> cluster.mode='false') >> @primaryKey('threshold_id') >> define table ThresholdCache(threshold_id string, is_active bool, path_regex >> string, threshold_updated_at string, threshold_context object, cache_time >> long); >> >> from ConfigReloadTrigger join ThresholdTable >> select >> str:concat('threshold_rule_', ThresholdTable.id >> <http://thresholdtable.id/>) as threshold_id, >> ThresholdTable.is_active, >> ThresholdTable.path_regex, >> ThresholdTable.updated_at as threshold_updated_at, >> map:create( >> "id", ThresholdTable.id <http://thresholdtable.id/>, >> "metric_name", ThresholdTable.metric_name, >> "path_regex", ThresholdTable.path_regex, >> "selectivity", ThresholdTable.selectivity, >> "aggr_field", ThresholdTable.aggr_field, >> "aggr_function", ThresholdTable.aggr_function, >> "warning", ThresholdTable.warning, >> "warning_action", ThresholdTable.warning_action, >> "critical", ThresholdTable.critical, >> "critical_action", ThresholdTable.critical_action, >> "is_active", ThresholdTable.is_active, >> "task_step_id", ThresholdTable.task_step_id, >> "created_at", ThresholdTable.created_at, >> "updated_at", ThresholdTable.updated_at >> ) as threshold_context, >> eventTimestamp() as cache_time >> insert into ThresholdTableStream; >> >> from ThresholdTableStream#log(true) >> select >> ThresholdTableStream.threshold_id, >> ThresholdTableStream.is_active, >> ThresholdTableStream.path_regex, >> ThresholdTableStream.threshold_updated_at, >> ThresholdTableStream.threshold_context, >> ThresholdTableStream.cache_time >> update or insert into ThresholdCache >> set >> ThresholdCache.threshold_id = threshold_id, >> ThresholdCache.is_active = is_active, >> ThresholdCache.path_regex = path_regex, >> ThresholdCache.threshold_updated_at = threshold_updated_at, >> ThresholdCache.threshold_context = threshold_context, >> ThresholdCache.cache_time = cache_time >> on ThresholdCache.threshold_id == threshold_id; >> >> _______________________________________________ >> Dev mailing list >> [email protected] >> http://wso2.org/cgi-bin/mailman/listinfo/dev >> > > > -- > *V. Mohanadarshan* | Technical Lead | WSO2 Inc. <http://www.wso2.com/> | > (M) 94-771117673 | (E) [email protected] | > GET INTEGRATION AGILE > Integration Agility for Digitally Driven Business > -- *Anusha Jayasundara* Software Engineer | WSO2 Email : [email protected] Mobile : +94772601160 Web : http://wso2.com Lean.Enterprise.Middleware <http://wso2.com/signature>
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
