| CPC G06F 16/258 (2019.01) [G06F 16/211 (2019.01); G06F 16/252 (2019.01); G06F 16/284 (2019.01)] | 20 Claims |
|
1. A system, comprising:
one or more computing devices, respectively comprising at least one processor and a memory that implement a data stream conversion service, configured to:
receive a request to initiate streaming replication from a non-relational database to a relational database;
evaluate at least a portion of the non-relational database, wherein the evaluation identifies one or more attributes of the non-relational database, wherein the one or more attributes are associated with first respective data types of the one or more attributes supported by the non-relational database;
generate a schema for the relational database, wherein the schema comprises:
one or more fields that correspond to respective ones of the identified one or more attributes; and
second respective data types supported by the relational database for the one or more fields that correspond to the first respective data types of the identified one or more attributes supported by the non-relational database;
replicate the streaming data from the non-relational database to the relational database, wherein to replicate, the data stream conversion service is configured to:
create one or more tables at the relational database according to the generated schema;
receive a change log stream for the non-relational database, wherein the change log stream describes changes performed at the non-relational database;
convert the changes performed at the non-relational database that are described in the received change log stream of the non-relational database into an update stream comprising updates to be made for the relational database in accordance with the generated schema; and
make, based on the update stream, corresponding changes to the one or more tables at the relational database in accordance with the generated schema.
|