Question on TimeStream DB

0

Hi team, would like to know , Is there a possibility / use case, where Postgre SQL Write Ahead Logs (WAL) (which is mainly used for database backup recovery functionality) can be used / considered as a Event data or Source data and this WAL logs further can be processed , transform through Kinesis data streams and Load into destination db i.e. AWS Time stream database . just try to show in diagram

---- source --- ----Data processing----- Target DB Postgre SQL (WAL Logs) -----> Kinesis Data Streams (with Lambda) -------> Time Stream DB

Is this architecture is feasible ? as per my understanding , Time Stream DB stores the device / sensor /web logs data and time stream can be considered as Primary DB always . please add your thoughts Regards, Mangesh

질문됨 2년 전396회 조회
1개 답변
0

PostgreSQL WAL logs are in binary format mainly used for backup and streaming replication and cannot be parsed by any other application or services. To capture the steam of changes to the PostgreSQL database , you can implement logical replication as mentioned in https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/CHAP_PostgreSQL.html#PostgreSQL.Concepts.General.FeatureSupport.LogicalReplication as the source for kinesis data stream.

AWS
답변함 2년 전
  • Hi Raj, thanks for clarifying , so what i understood here , i) these WAL logs has only useful in backup and recovery , streaming replication etc. but same WAL logs (which is binary in nature) cannot parse by any application like python , i mean it can not be converted into a typical database record . please correct me. 2) here we wants to use this WAL logs as a source and want to transform such logs into a database record. after that , delta capture needs to do from WAL logs which is different for each table. but i believe WAL logs capture all the logs in database irrespective of changes in all the database tables ( for e.g. 10 tables are getting insert and updated) 3) As we can implement logical replication , so what is purpose of replication ? i believe , WAL logs are not meant for processing Delta records or any ETL transformation work , please correct me . Thanks in Advance

로그인하지 않았습니다. 로그인해야 답변을 게시할 수 있습니다.

좋은 답변은 질문에 명확하게 답하고 건설적인 피드백을 제공하며 질문자의 전문적인 성장을 장려합니다.

질문 답변하기에 대한 가이드라인

관련 콘텐츠