使用 Amazon Aurora 数据库时出现的问题

Issues while working with Amazon Aurora Database

我的要求:

  1. 我想将来自 e-commerce 个网站的 real-time events data 存储到数据库中
  2. 在存储数据的同时,我想从数据库access the events data
  3. 我想执行某种 ad-hoc analysis(SQL)
  4. 使用某种 built-in methods(either from Boto3 or JAVA SDK),我想访问事件数据
  5. 我想创建某种 Custom-API's 来访问存储在数据库中的事件数据

我最近遇到了 Amazon Aurora(mysql) database.

我认为 Aurora 是满足我的要求的好例子之一。但是当我深入研究这个 Amazon Aurora(mysql) 时,我注意到我们可以使用 AWS-CDK

创建一个 database

但是

1.没有使用 AWS-CDK/BOTO3

创建 table 的等效方法

2。 BOTO3 或 JAVA SDK 中没有与 store/access 数据库数据

等效的方法

谁能告诉我如何在 AURORA 数据库中使用 (IAC) 创建 table?

谁能告诉我如何将实时数据存储到 AURORA 中?

谁能告诉我如何访问 AURORA 中存储的实时数据?

  1. No equivalent methods to create tables using AWS-CDK/BOTO3

这是因为使用 Data API 只能访问 Aurora Serveless,而不能访问常规数据库。

您必须使用常规 mysql 工具(例如,mysql cli、phpmyadminmysql workbench 等)来创建表并填充它们。

  1. No equivalent methods in BOTO3 or JAVA SDK to store/access the database data

与第 1 点相同的原因和解决方案。

  1. Can anyone tell me how i can create a table using(IAC) in AURORA db?

Terraform 有 mysql,但它不是用于表,而是用于用户和数据库。

Can anyone tell me how i can store realtime data into AURORA?

没有开箱即用的解决方案,因此您需要定制解决方案。也许将数据流式传输到 Kinesis Streams or Firehose,然后传输到 lambda,lambda 将填充您的数据库?似乎最容易实施。

Can anyone tell me how i can access realtime data stored in AURORA?

如果您先将数据流式传输到 Kinesis Stream,您可以使用 Kinesis Analytics 对其进行实时分析。

由于以上许多要求定制解决方案,其他架构也是可能的。

将连接管理器创建为 DriverManager.getConnection( "jdbc:mysql://localhost:3306/$dbName", //用你的端点和数据库名称替换这里 “根”, “admin123” ) 然后 val stmt: 语句 = con.createStatement() stmt.executeQuery("使用产品目录信息;") 每当您的 lambda 触发时,它也会执行此连接和 DDL 操作。