Autonomous Database：S3にファイルがアップロードされたらすぐに表にロードし、ロード完了後にS3上のファイルを削除する

# はじめに

[こちらの記事](https://qiita.com/500InternalServerError/items/fac9e8d5d7638a4a4020)の応用編として、Amazon S3バケットにファイルがアップロードされたら、それをトリガーにしてLambdaファンクションが起動、起動したLambdaファンクションがAutonomous Databaseに接続してアップロードされたファイルを表にロードし、ロード後にロードしたファイルをAmazon S3から削除する仕組みを構築してみました。

処理の流れのイメージは以下のようになります。

1. Amazon S3のバケットにファイルをアップロード

2. Amazon S3バケットのオブジェクト作成イベントをLambdaに通知

3. LambdaからAutonomous Databaseにアクセス

4. Amazon S3にアップロードされたファイルを表にロードし、ロード後にファイルを削除するPL/SQLプロシージャをLambdaから実行

5. PL/SQLプロシージャによって、Amazon S3にアップロードされたファイルが表にロードされ、その後ファイルが削除される

※なお、Python、Lambdaに関して初心者ですので、最低限動くといったコーディング、設定しか行っていません。実装にあたっては、エラーハンドリング等を追加し充分に検証を行ってから実装してください。こちらの内容を元に実装されたことによる問題について、当方は一切の責任を負いません。
また、こちらの内容に関するOracle Supportへのご質問等はご遠慮ください。

# 1. 事前準備
バケットload-and-delete-buketを作成し、empdata1.csvをアップロードします。
![スクリーンショット 2024-07-31 18.15.48.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/48652473-2981-20be-cad4-1c0a3af05efd.png)

empdata1.csvの内容は以下の通りです。
```text:empdata1.csv
1,SMITH
2,ALLEN
3,WARD
```

S3にアップロードされたファイルのロード先となる表empdataを作成します。
```
SQL> CREATE TABLE empdata (
  2  	 id   NUMBER,
  3  	 name VARCHAR2(20)
  4  );

Table created.

SQL> 
```

# 2. PL/SQLプロシージャの作成と動作確認
バケット名とオブジェクト名（ファイル名）をパラメータとして受け取り、パラメータで指定されたS3上のファイルを表にロードし、ロード後にS3上のファイルを削除するプロシージャload_and_deleteを作成します。

```
SQL> CREATE OR REPLACE PROCEDURE load_and_delete ( bucket_name IN VARCHAR2, object_name IN VARCHAR2)
  2  IS
  3  	 object_uri VARCHAR2(1024) := 'https://'||bucket_name||'.s3.ap-northeast-1.amazonaws.com/'||object_name;
  4  	 table_name VARCHAR2(128)  := 'empdata';
  5  	 cred_name  VARCHAR2(128)  := 'AWS_S3_CRED';
  6  BEGIN
  7  	 DBMS_OUTPUT.PUT_LINE('object_uri:'||object_uri);
  8  
  9  	 DBMS_CLOUD.COPY_DATA(
 10  	     table_name      => table_name,
 11  	     credential_name => cred_name,
 12  	     file_uri_list   => object_uri,
 13  	     format	     => json_object('delimiter' value ',')
 14  	 );
 15  
 16  	 DBMS_CLOUD.DELETE_OBJECT(
 17  	     credential_name => cred_name,
 18  	     object_uri      => object_uri
 19  	 );
 20  END;
 21  /

Procedure created.

SQL> 
```

対象のバケットにアクセスできることを確認します。
```
SQL> col object_name for a30
SQL> SELECT object_name, bytes FROM
  2  DBMS_CLOUD.LIST_OBJECTS(
  3  	 'AWS_S3_CRED',
  4  	 'https://load-and-delete-bucket.s3.ap-northeast-1.amazonaws.com/'
  5  );

OBJECT_NAME			                BYTES
------------------------------ ----------
empdata1.csv			               22

SQL> 
```
empdata表が空であることを確認します。
```
SQL> SELECT * FROM empdata;

no rows selected

SQL>
```
バケット名「load-and-delete-bucket」、ファイル名「empdata1.csv」をパラメータとして渡して、プロシージャload_and_deleteを実行してみます。
```
SQL> set serveroutput on
SQL> EXEC load_and_delete('load-and-delete-bucket','empdata1.csv')
object_uri:https://load-and-delete-bucket.s3.ap-northeast-1.amazonaws.com/empdat
a1.csv

PL/SQL procedure successfully completed.

SQL>
```
empdata表の内容を確認します。
```
SQL> SELECT * FROM empdata;

	    ID NAME
---------- --------------------
	     1 SMITH
	     2 ALLEN
	     3 WARD

SQL>
```
empdata1.csvの内容がempdata表にロードされていることが確認できました。

S3バケットの内容を確認します。
```
SQL> SELECT * FROM
  2  DBMS_CLOUD.LIST_OBJECTS(
  3  	 'AWS_S3_CRED',
  4  	 'https://load-and-delete-bucket.s3.ap-northeast-1.amazonaws.com/'
  5  );

no rows selected

SQL>
```
ファイルempdata1.csvが削除されていることが確認できました。

# 3. Lambdaファンクションの作成
sam initを実行して新規アプリケーションを初期化します。
今回はAWS Quick Start Templatesに用意されているHello World Exampleをテンプレートとして使用しました。
プロジェクト名はload-and-deleteとしました。

```
(mypy) kyamakaw@kyamakaw-mac sam % sam init

You can preselect a particular runtime or package type when using the `sam init` experience.
Call `sam init --help` to learn more.

Which template source would you like to use?
	1 - AWS Quick Start Templates
	2 - Custom Template Location
Choice: 1

Choose an AWS Quick Start application template
	1 - Hello World Example
	2 - Data processing
	3 - Hello World Example with Powertools for AWS Lambda
	4 - Multi-step workflow
	5 - Scheduled task
	6 - Standalone function
	7 - Serverless API
	8 - Infrastructure event management
	9 - Lambda Response Streaming
	10 - Serverless Connector Hello World Example
	11 - Multi-step workflow with Connectors
	12 - GraphQLApi Hello World Example
	13 - Full Stack
	14 - Lambda EFS example
	15 - DynamoDB Example
	16 - Machine Learning
Template: 1

Use the most popular runtime and package type? (Python and zip) [y/N]: y

Would you like to enable X-Ray tracing on the function(s) in your application?  [y/N]: 

Would you like to enable monitoring using CloudWatch Application Insights?
For more info, please view https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/cloudwatch-application-insights.html [y/N]: 

Would you like to set Structured Logging in JSON format on your Lambda functions?  [y/N]: 

Project name [sam-app]: load-and-delete

    -----------------------
    Generating application:
    -----------------------
    Name: load-and-delete
    Runtime: python3.9
    Architectures: x86_64
    Dependency Manager: pip
    Application Template: hello-world
    Output Directory: .
    Configuration file: load-and-delete/samconfig.toml
    
    Next steps can be found in the README file at load-and-delete/README.md
        

Commands you can use next
=========================
[*] Create pipeline: cd load-and-delete && sam pipeline init --bootstrap
[*] Validate SAM template: cd load-and-delete && sam validate
[*] Test Function in the Cloud: cd load-and-delete && sam sync --stack-name {stack-name} --watch

(mypy) kyamakaw@kyamakaw-mac sam %
```

作成されたディレクトリload-and-deleteに移動します。
```
(mypy) kyamakaw@kyamakaw-mac sam % cd load-and-delete 
(mypy) kyamakaw@kyamakaw-mac load-and-delete % ls
README.md	events		samconfig.toml	tests
__init__.py	hello_world	template.yaml
(mypy) kyamakaw@kyamakaw-mac load-and-delete %
```
ディレクトリhello_worldに移動します。
```
(mypy) kyamakaw@kyamakaw-mac load-and-delete % cd hello_world 
(mypy) kyamakaw@kyamakaw-mac hello_world % ls
__init__.py		app.py			requirements.txt
(mypy) kyamakaw@kyamakaw-mac hello_world %
```
Autonomous Databaseへのアクセスにpython-oracledbを使用するので、reqirements.txtにoracledbを追加します。
```
(mypy) kyamakaw@kyamakaw-mac hello_world % vi requirements.txt 
```

oracledbを追加して保存します。
```
requests
oracledb
```
アプリケーション本体のapp.pyを編集し、以下のような内容に書き換えます。
```
import json
import oracledb
import os

# 環境変数を取得
un = os.environ.get('PYTHON_USERNAME')
pw = os.environ.get('PYTHON_PASSWORD')
cs = os.environ.get('PYTHON_CONNECTSTRING')

def lambda_handler(event, context):
# イベント通知からバケット名とオブジェクト名を取得
    bucket_name = event['Records'][0]['s3']['bucket']['name']
    object_name = event['Records'][0]['s3']['object']['key']
    
# Autonomous Databaseに接続し、バケット名、オブジェクト名を引数としてload-and-deleteプロシージャを実行
    with oracledb.connect(user=un, password=pw, dsn=cs) as connection:
        with connection.cursor() as cursor:
            cursor.callproc('load_and_delete', [bucket_name, object_name])

    return {
        "statusCode": 200,
        "body": json.dumps({
            "message": "hello world",
            # "location": ip.text.replace("\n", "")
        }),
    }
```
ディレクトリload-and-deleteに移動します。
```
(mypy) kyamakaw@kyamakaw-mac hello_world % cd ..
```
sam buildでアプリケーションをビルドを実行します。
```
(mypy) kyamakaw@kyamakaw-mac load-and-delete % sam build
Starting Build use cache                                                        
Manifest file is changed (new hash: 2768310a16637613860e1081461caa9f) or        
dependency folder (.aws-sam/deps/18fc3384-c7aa-4080-a286-f650ebdfd1bb) is       
missing for (HelloWorldFunction), downloading dependencies and copying/building 
source                                                                          
Building codeuri: /Users/kyamakaw/sam/load-and-delete/hello_world runtime:      
python3.9 metadata: {} architecture: x86_64 functions: HelloWorldFunction       
 Running PythonPipBuilder:CleanUp                                               
 Running PythonPipBuilder:ResolveDependencies                                   
 Running PythonPipBuilder:CopySource                                            
 Running PythonPipBuilder:CopySource                                            

Build Succeeded

Built Artifacts  : .aws-sam/build
Built Template   : .aws-sam/build/template.yaml

Commands you can use next
=========================
[*] Validate SAM template: sam validate
[*] Invoke Function: sam local invoke
[*] Test Function in the Cloud: sam sync --stack-name {{stack-name}} --watch
[*] Deploy: sam deploy --guided
(mypy) kyamakaw@kyamakaw-mac load-and-delete % 

```
sam deployでアプリケーションをLambdaにファンクションとしてデプロイします。
```
(mypy) kyamakaw@kyamakaw-mac load-and-delete % sam deploy --stack-name load-and-delete --guided

Configuring SAM deploy
======================

	Looking for config file [samconfig.toml] :  Found
	Reading default arguments  :  Success

	Setting default arguments for 'sam deploy'
	=========================================
	Stack Name [load-and-delete]: 
	AWS Region [ap-northeast-1]: 
	#Shows you resources changes to be deployed and require a 'Y' to initiate deploy
	Confirm changes before deploy [Y/n]: 
	#SAM needs permission to be able to create roles to connect to the resources in your template
	Allow SAM CLI IAM role creation [Y/n]: 
	#Preserves the state of previously provisioned resources when an operation fails
	Disable rollback [y/N]: 
	HelloWorldFunction has no authentication. Is this okay? [y/N]: y
	Save arguments to configuration file [Y/n]: 
	SAM configuration file [samconfig.toml]: 
	SAM configuration environment [default]: 

	Looking for resources needed for deployment:

	Managed S3 bucket: aws-sam-cli-managed-default-samclisourcebucket-e7cuyvsbwyhw
	A different default S3 bucket can be set in samconfig.toml and auto resolution of buckets turned off by setting resolve_s3=False
                                                                                
        Parameter "stack_name=load-and-delete" in [default.deploy.parameters] is
defined as a global parameter [default.global.parameters].                      
        This parameter will be only saved under [default.global.parameters] in  
/Users/kyamakaw/sam/load-and-delete/samconfig.toml.                             

	Saved arguments to config file
	Running 'sam deploy' for future deployments will use the parameters saved above.
	The above parameters can be changed by modifying samconfig.toml
	Learn more about samconfig.toml syntax at 
	https://docs.aws.amazon.com/serverless-application-model/latest/developerguide/serverless-sam-cli-config.html

File with same data already exists at                                           
load-and-delete/93c5aeedad5e5506dd94db3354b56a73, skipping upload               

	Deploying with following values
	===============================
	Stack name                   : load-and-delete
	Region                       : ap-northeast-1
	Confirm changeset            : True
	Disable rollback             : False
	Deployment s3 bucket         : aws-sam-cli-managed-default-samclisourcebucket-e7cuyvsbwyhw
	Capabilities                 : ["CAPABILITY_IAM"]
	Parameter overrides          : {}
	Signing Profiles             : {}

Initiating deployment
=====================

File with same data already exists at                                           
load-and-delete/5b105969a61b42a0543907292509f35b.template, skipping upload      


Waiting for changeset to be created..

CloudFormation stack changeset
-------------------------------------------------------------------------------------------------
Operation                LogicalResourceId        ResourceType             Replacement            
-------------------------------------------------------------------------------------------------
+ Add                    HelloWorldFunctionHell   AWS::Lambda::Permissio   N/A                    
                         oWorldPermissionProd     n                                               
+ Add                    HelloWorldFunctionRole   AWS::IAM::Role           N/A                    
+ Add                    HelloWorldFunction       AWS::Lambda::Function    N/A                    
+ Add                    ServerlessRestApiDeplo   AWS::ApiGateway::Deplo   N/A                    
                         yment47fc2d5f9d          yment                                           
+ Add                    ServerlessRestApiProdS   AWS::ApiGateway::Stage   N/A                    
                         tage                                                                     
+ Add                    ServerlessRestApi        AWS::ApiGateway::RestA   N/A                    
                                                  pi                                              
-------------------------------------------------------------------------------------------------


Changeset created successfully. arn:aws:cloudformation:ap-northeast-1:010446572587:changeSet/samcli-deploy1722424715/645c64ba-bbc0-4477-90db-03dc87cd7c34


Previewing CloudFormation changeset before deployment
======================================================
Deploy this changeset? [y/N]: y

2024-07-31 20:18:44 - Waiting for stack create/update to complete

CloudFormation events from stack operations (refresh every 5.0 seconds)
-------------------------------------------------------------------------------------------------
ResourceStatus           ResourceType             LogicalResourceId        ResourceStatusReason   
-------------------------------------------------------------------------------------------------
CREATE_IN_PROGRESS       AWS::CloudFormation::S   load-and-delete          User Initiated         
                         tack                                                                     
CREATE_IN_PROGRESS       AWS::IAM::Role           HelloWorldFunctionRole   -                      
CREATE_IN_PROGRESS       AWS::IAM::Role           HelloWorldFunctionRole   Resource creation      
                                                                           Initiated              
CREATE_COMPLETE          AWS::IAM::Role           HelloWorldFunctionRole   -                      
CREATE_IN_PROGRESS       AWS::Lambda::Function    HelloWorldFunction       -                      
CREATE_IN_PROGRESS       AWS::Lambda::Function    HelloWorldFunction       Resource creation      
                                                                           Initiated              
CREATE_IN_PROGRESS       AWS::Lambda::Function    HelloWorldFunction       Eventual consistency   
                                                                           check initiated        
CREATE_IN_PROGRESS       AWS::ApiGateway::RestA   ServerlessRestApi        -                      
                         pi                                                                       
CREATE_IN_PROGRESS       AWS::ApiGateway::RestA   ServerlessRestApi        Resource creation      
                         pi                                                Initiated              
CREATE_COMPLETE          AWS::ApiGateway::RestA   ServerlessRestApi        -                      
                         pi                                                                       
CREATE_IN_PROGRESS       AWS::ApiGateway::Deplo   ServerlessRestApiDeplo   -                      
                         yment                    yment47fc2d5f9d                                 
CREATE_IN_PROGRESS       AWS::Lambda::Permissio   HelloWorldFunctionHell   -                      
                         n                        oWorldPermissionProd                            
CREATE_IN_PROGRESS       AWS::Lambda::Permissio   HelloWorldFunctionHell   Resource creation      
                         n                        oWorldPermissionProd     Initiated              
CREATE_IN_PROGRESS       AWS::ApiGateway::Deplo   ServerlessRestApiDeplo   Resource creation      
                         yment                    yment47fc2d5f9d          Initiated              
CREATE_COMPLETE          AWS::Lambda::Function    HelloWorldFunction       -                      
CREATE_COMPLETE          AWS::Lambda::Permissio   HelloWorldFunctionHell   -                      
                         n                        oWorldPermissionProd                            
CREATE_COMPLETE          AWS::ApiGateway::Deplo   ServerlessRestApiDeplo   -                      
                         yment                    yment47fc2d5f9d                                 
CREATE_IN_PROGRESS       AWS::ApiGateway::Stage   ServerlessRestApiProdS   -                      
                                                  tage                                            
CREATE_IN_PROGRESS       AWS::ApiGateway::Stage   ServerlessRestApiProdS   Resource creation      
                                                  tage                     Initiated              
CREATE_COMPLETE          AWS::ApiGateway::Stage   ServerlessRestApiProdS   -                      
                                                  tage                                            
CREATE_COMPLETE          AWS::CloudFormation::S   load-and-delete          -                      
                         tack                                                                     
-------------------------------------------------------------------------------------------------

CloudFormation outputs from deployed stack
-------------------------------------------------------------------------------------------------
Outputs                                                                                         
-------------------------------------------------------------------------------------------------
Key                 HelloWorldFunctionIamRole                                                   
Description         Implicit IAM Role created for Hello World function                          
Value               arn:aws:iam::010446572587:role/load-and-delete-HelloWorldFunctionRole-      
bHr0gamyWnao                                                                                    

Key                 HelloWorldApi                                                               
Description         API Gateway endpoint URL for Prod stage for Hello World function            
Value               https://halylnj5x6.execute-api.ap-northeast-1.amazonaws.com/Prod/hello/     

Key                 HelloWorldFunction                                                          
Description         Hello World Lambda Function ARN                                             
Value               arn:aws:lambda:ap-northeast-1:010446572587:function:load-and-delete-        
HelloWorldFunction-EX6cP40ohBwp                                                                 
-------------------------------------------------------------------------------------------------


Successfully created/updated stack - load-and-delete in ap-northeast-1

(mypy) kyamakaw@kyamakaw-mac load-and-delete % 
```
デプロイが完了したら、AWSコンソールからデプロイされたLambdaファンクションを確認します。
![スクリーンショット 2024-07-31 20.20.33.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/9fdb965b-415b-01bb-a215-1f73a177b887.png)

Lambdaファンクションが作成できました。

# 4. Lambdaファンクションの設定
ファンクション名をクリックして、ファンクションの詳細を表示します。
![スクリーンショット 2024-07-31 20.20.47.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/acc88186-26c5-f3ee-f655-4348e8c99baf.png)

「設定」タブをクリックします。
![スクリーンショット 2024-07-31 20.20.59.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/552a3b64-333b-f606-552e-5e23e055e9ea.png)

「トリガー」を選択し、「トリガーを追加」をクリックします。
![スクリーンショット 2024-07-31 20.22.50.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/13dbed7a-6c62-50b8-32ba-90d2a3bc4373.png)
ソースにS3を選択、バケットにload-and-delete-bucketを指定します。
イベントタイプはデフォルトの「すべてのオブジェクト作成イベント」のみにします。
![スクリーンショット 2024-07-31 20.23.10.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/86462069-9013-b39d-2562-d415d272039e.png)
入力が完了したら、「追加」をクリックしてトリガーを追加します。
![スクリーンショット 2024-07-31 20.23.18.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/18cd67c0-9d4d-c14d-7489-1cb1436a28cb.png)
Lambdaファンクションにトリガーが追加されました。
![スクリーンショット 2024-07-31 20.23.36.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/289f44d6-ff4f-c676-15ef-517a3f859e57.png)
左側のメニューから「環境変数」を選択します。
![スクリーンショット 2024-07-31 20.23.46.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/dfe3ea39-7377-3e8a-1dcb-1f569856153f.png)
「編集」をクリックします。
![スクリーンショット 2024-07-31 20.24.01.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/3770a34d-e186-404f-dee1-a5a20c2a4b66.png)
Lambdaファンクションの環境変数を設定します。
今回は、Autonomous Databaseに接続する際のユーザ名、パスワード、接続文字列を環境変数に設定し、Lambdaファンクションから参照します。
PYTHON_USERNAME：ユーザ名
PYTHON_PASSWORD：パスワード
PYTHON_CONNECTSTRING：接続文字列
環境変数のキーにPYTHON_USERNAME、PYTHON_PASSWORD、PYTHON_CONNECTSTRINGを追加し、それぞれの値を設定して「保存」をクリックします。
![スクリーンショット 2024-07-31 20.25.03.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/3799d91d-1fd8-23be-dc97-1092c3d6479b.png)
環境変数が設定できました。
![スクリーンショット 2024-07-31 20.25.14.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/a28ec3aa-e607-ad4a-2bfd-06cb91f989d8.png)

![スクリーンショット 2024-07-31 20.25.22.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/c283bc6e-e9f3-fdf0-a2da-9d4acd4df7ed.png)


# 5. 動作確認

TRANCATE TABLE文でempdata表を空にします。
```
SQL> TRUNCATE TABLE empdata;

Table truncated.

SQL> SELECT * FROM empdata;

no rows selected

SQL>
```
AWSコンソールからload-and-delete-bucketにアクセスし、「アップロード」をクリックします。
![スクリーンショット 2024-07-31 20.25.51.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/6802b53e-7d97-a3db-80d7-93186ed2289d.png)
empdata1.csvをアップロードします
empdata1.csvの内容は以下の通りです。
```text:empdata1.csv
1,SMITH
2,ALLEN
3,WARD
```
![スクリーンショット 2024-07-31 20.26.06.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/30b55b3e-a58f-4619-44b7-2e74f2610e5b.png)

![スクリーンショット 2024-07-31 20.26.21.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/60a474cc-3a1d-e995-245c-9c72c02ff39b.png)
アップロードが完了したら、「閉じる」をクリックします。
![スクリーンショット 2024-07-31 20.26.30.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/2d980bb3-c244-a8ec-050b-57c31a6019cb.png)
バケット内にアップロードしたはずのファイルがありません。
![スクリーンショット 2024-07-31 20.31.42.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/6b379449-729c-e01d-77c4-aa970d9fde91.png)

empdata表の内容を確認してみます。
```
SQL> SELECT * FROM empdata;

	    ID NAME
---------- --------------------
	     1 SMITH
	     2 ALLEN
	     3 WARD

SQL>
```
S3にアップロードしたファイルempdata1.csvの内容がempdata表にロードされていることが確認できました。

さらにS3にファイルempdata2.csvをアップロードしてみます。
empdata2.csvの内容は以下の通りです。
```text:empdata2.csv
4,JACKSON
5,BROWN
6,TURNER

```
empdata2.csvをアップロードします
![スクリーンショット 2024-07-31 20.39.38.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/20d18a2a-7f98-efde-9b0c-6dc27a927962.png)

![スクリーンショット 2024-07-31 20.39.47.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/9e329fd9-193c-024f-5a86-351df76e5683.png)

アップロードが完了したら、「閉じる」をクリックします。
![スクリーンショット 2024-07-31 20.39.56.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/aa33541e-a997-cdce-63a4-9d7cfa83e28d.png)
先ほどと同様に、バケット内にアップロードしたはずのファイルがありません。
![スクリーンショット 2024-07-31 20.40.06.png](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/784824/05c4679b-7e42-3f1b-309c-4fcd0a469f46.png)

empdata表の内容を確認してみます。
```
SQL> SELECT * FROM empdata;

	    ID NAME
---------- --------------------
	     1 SMITH
	     2 ALLEN
	     3 WARD
	     4 JACKSON
	     5 BROWN
	     6 TURNER

6 rows selected.

SQL>
```
empdata2.csvの内容がempdata表に追加されていることが確認できました。

# 6. まとめ
Amazon S3にファイルがアップされたことをトリガーにして、そのファイルをAutonomous Database内の表にロードし、データのロード後にロードしたファイルをS3から削除する処理を実装することができました。
今回作成したPL/SQLプロシージャload_and_deleのDELETE_OBJECTプロシージャの部分をMOVE_OBJECTに変更することで、データのロード後にロードが完了したファイルを別のバケットに移動するといったことも可能になります。

# 参考情報
・[Amazonリソース名(ARN)を使用したAWSリソースへのアクセス](https://docs.oracle.com/cd/E83857_01/paas/autonomous-database/serverless/adbsb/amazon-arn.html#GUID-BDEE5519-3807-4699-9C53-546EFD2F3A17)
・[AWS CLIの最新バージョンのインストールまたは更新](https://docs.aws.amazon.com/ja_jp/cli/latest/userguide/getting-started-install.html)
・[AWS SAM CLI のインストール](https://docs.aws.amazon.com/ja_jp/serverless-application-model/latest/developerguide/install-sam-cli.html)
・[sam init コマンドを使用してアプリケーションを作成する](https://docs.aws.amazon.com/ja_jp/serverless-application-model/latest/developerguide/using-sam-cli-init.html)
・[sam build](https://docs.aws.amazon.com/ja_jp/serverless-application-model/latest/developerguide/sam-cli-command-reference-sam-build.html)
・[sam deploy](https://docs.aws.amazon.com/ja_jp/serverless-application-model/latest/developerguide/sam-cli-command-reference-sam-deploy.html)
・[The python-oracledb driver for Oracle Database](https://oracle.github.io/python-oracledb/)
・[DBMS_CLOUD.LIST_OBJECTSファンクション](https://docs.oracle.com/cd/F19136_01/arpls/DBMS_CLOUD.html#GUID-52801F96-8280-4FE0-8782-E194F4360E6F)
・[DBMS_CLOUD.COPY_DATAプロシージャ](https://docs.oracle.com/cd/F19136_01/arpls/DBMS_CLOUD.html#GUID-9428EA51-5DDD-43C2-B1F5-CD348C156122)
・[DBMS_CLOUD.DELETE_OBJECTプロシージャ](https://docs.oracle.com/cd/F19136_01/arpls/DBMS_CLOUD.html#GUID-F3DE3030-6A76-4943-8FEA-649393B66DB0)