Resources:
  MyTableItem:
    Type: "AwsCommunity::DynamoDB::Item"
    Properties:
      TableName: !Ref TableName
      Item:
        configItem:
          S: "exampleConfig"
        configValue:
          S: "exampleValue"

$ aws cloudformation deploy \
--stack-name rds \
--template-file rds.yaml

2.  要開發資源型別處理程式，我們還需要CloudFormation CLI的Python外掛。讓我們也安裝它：

    ```bash
$ pip install cloudformation-cli-python-plugin

4.  我們將構建自定義資源型別，因此第一個問題的答案很明確：

    ```
Initializing new project
Do you want to develop a new resource(r) or a module(m) or a hook(h)?.
>> r

What's the name of your resource type?
(Organization::Service::Resource)
>> Org::Storage::Database

2. 按照提示輸入專案相關資訊，包括資源型別的名稱和描述。

### 步驟二：選擇程式語言和設定
1. 選擇您偏好的程式語言。在本例中，我們選擇最新的 Python 版本：

2. 使用 Docker 進行平台無關的封裝：

### 步驟三：檢視專案結構
成功初始化專案後，您將看到以下目錄結構：
```plaintext
.
├── README.md
├── docs
│ ├── README.md
│ ├── memo.md
│ └── tag.md
├── example_inputs
│ ├── inputs_1_create.json
│ ├── inputs_1_invalid.json
│ └── inputs_1_update.json
├── org-storage-database.json
├── requirements.txt
├── resource-role.yaml
├── rpdk.log
├── src
│ └── org_storage_database
│ ├── __init__.py
│ ├── handlers.py
│ └── models.py
└── template.yml

#### 內容解密：
- `typeName`：定義了資源型別的名稱。
- `description`：提供了對資源型別的簡要描述。
- `replacementStrategy`：指定了更新資源時的策略。
- `properties`：定義了資源的屬性，包括資料函式庫名稱、使用者名稱和密碼等。
- `required`：列出了建立資源所需的必要屬性。
- `primaryIdentifier`：指定了資源的主要識別符。
- `handlers`：定義了不同操作的許可權。

### 步驟五：生成專案檔案
執行以下命令以根據 schema 生成專案檔案：
```bash
cfn generate

#### 內容解密：
- `__init__` 方法初始化了資料函式庫連線。
- 定義了多個靜態 SQL 查詢範本，用於建立資料函式庫、使用者、授權和刪除資料函式庫。


## 在AWS CloudFormation中建立與使用私有擴充套件：探討RDS資源管理

在前一章中，我們已經瞭解瞭如何使用AWS CloudFormation來管理和佈署資源。在本章中，我們將探討如何建立和使用私有擴充套件，以更好地管理RDS資源。

### 建立私有擴充套件的必要性

AWS CloudFormation提供了許多內建資源型別，但有時我們需要管理特定的資源或執行自定義邏輯。這時，建立私有擴充套件就變得非常必要。私有擴充套件允許我們定義自定義資源型別，並使用AWS CloudFormation來管理和佈署這些資源。

### 建立RDS資源的私有擴充套件

在我們的例子中，我們將建立一個私有擴充套件來管理RDS資源。我們將定義一個自定義資源型別`My::RDS::Database`，並使用它來建立和管理RDS資料函式庫例項。

#### 步驟1：定義資源型別

首先，我們需要定義資源型別的結構和屬性。在我們的例子中，`My::RDS::Database`資源型別將具有以下屬性：

- `DatabaseName`：資料函式庫名稱
- `DatabaseUser`：資料函式庫使用者名稱
- `DatabasePassword`：資料函式庫密碼
- `RdsHost`：RDS例項主機名稱
- `RdsUser`：RDS例項使用者名稱
- `RdsPassword`：RDS例項密碼

#### 步驟2：實作資源邏輯

接下來，我們需要實作資源邏輯，包括建立、更新、刪除和讀取資源。我們將使用Python來實作這些邏輯。

```python
class DbClient:
    def __init__(self, host, user, password):
        self.host = host
        self.user = user
        self.password = password
        self.cursor = self._get_db_connection()

    def _get_db_connection(self):
        # 建立與RDS例項的連線
        # 省略實作細節
        pass

    def db_exists(self, db):
        query = "SHOW DATABASES LIKE '{}'".format(db)
        if self.cursor.execute(query):
            return True
        return False

    def user_exists(self, user):
        query = "SELECT user FROM mysql.user where user='{}'".format(user)
        if self.cursor.execute(query):
            return True
        return False

    def create_or_update(self, db, user, pw):
        if self.db_exists(db):
            self.delete_db(db)
        if self.user_exists(user):
            self.delete_user(user)
        self.cursor.execute("CREATE USER '{}'@'%' IDENTIFIED BY '{}'".format(user, pw))
        self.cursor.execute("CREATE DATABASE {}".format(db))
        self.cursor.execute("GRANT ALL PRIVILEGES ON {}.{} TO '{}'@'%'".format(db, '*', user))
        self.cursor.execute("FLUSH PRIVILEGES")

    def delete(self, db, user):
        if self.db_exists(db):
            self.delete_db(db)
        if self.user_exists(user):
            self.delete_user(user)

    def change_user_password(self, user, pw):
        if not self.user_exists(user):
            raise ValueError('User {} does not exist!'.format(user))
        self.cursor.execute("ALTER USER '{}'@'%' IDENTIFIED BY '{}'".format(user, pw))

@resource.handler(Action.CREATE)
def create_handler(session, request, callback_context):
    host, rds_user, rds_pw = get_db_connection_parameters(request)
    db, user, pw = get_db_properties(request)
    client = DbClient(host, rds_user, rds_pw)
    if client.user_exists(user) or client.db_exists(db):
        return ProgressEvent.failed(HandlerErrorCode.AlreadyExists)
    try:
        client.create_or_update(db, user, pw)
        progress.status = OperationStatus.SUCCESS
    except Exception as e:
        return ProgressEvent.failed(HandlerErrorCode.HandlerInternalFailure)
    return read_handler(session, request, callback_context)

@resource.handler(Action.UPDATE)
def update_handler(session, request, callback_context):
    # 省略實作細節
    pass

@resource.handler(Action.DELETE)
def delete_handler(session, request, callback_context):
    host, rds_user, rds_pw = get_db_connection_parameters(request)
    db, user, _ = get_db_properties(request)
    client = DbClient(host, rds_user, rds_pw)
    if not (client.db_exists(db) or client.user_exists(user)):
        return ProgressEvent.failed(HandlerErrorCode.NotFound)
    try:
        client.delete(db, user)
    except Exception as e:
        return ProgressEvent.failed(HandlerErrorCode.HandlerInternalFailure)
    return ProgressEvent(status=OperationStatus.SUCCESS)