第2章 Amazon S3 への接続

1. https://aws.amazon.com/s3/ にアクセスします。
2. アカウント で AWS マネジメントコンソール を選択します。アクセスするバケットを作成した AWS アカウントまたはバケットを作成するためにコネクションが使用するアカウントでコンソールにサインインします。
3. コンソール右上のユーザー名の横にある下矢印をクリックし、セキュリティ認証情報 をクリックします。
4. アクセスキー を展開し、新しいアクセスキーの作成スキーの作成 をクリックします。
5. プロンプトにしたがってキーを取得します。

手順

1. Fuse Online の左パネルで Connections をクリックし、利用可能なコネクションを表示します。
2. 右上にある Create Connection をクリックし、Fuse Online コネクターを表示します。
3. Amazon S3 コネクターをクリックします。
4. Access Key フィールドに、このコネクションがアクセスするバケットを作成した AWS アカウントの Amazon S3 アクセスキー ID を入力します。コネクションがアクセスするバケットが存在しない場合は、Fuse Online がインテグレーションの実行を開始しようとするときに、そのアクセスキーに関連する AWS アカウントを使用してバケットを作成します。しかし、他の AWS アカウントにバケットが存在する場合は、コネクションはバケットを作成できず、インテグレーションを開始できません。
5. Bucket Name or Amazon Resource Name フィールドに、このコネクションがアクセスするバケットの名前またはバケットの ARN を入力します。使用している AWS のアカウントまたは他の AWS アカウントにバケットが存在しない場合は、コネクションがこのバケットを作成します。
6. Region フィールドではバケットが存在する AWS リージョンを選択します。コネクションがバケットを作成する場合にここで選択されたリージョンに作成されます。
7. Secret Key フィールドに、このコネクションがアクセスするバケットを作成した (またはこれから作成する) アカウントの Amazon S3 シークレットアクセスキーを入力します。このキーは AWS によって提供されます。
8. Validate をクリックします。Fuse Online は即座にコネクションの検証を試み、検証の成功または失敗を示すメッセージを表示します。検証に失敗した場合は、必要に応じて設定の詳細を修正し、再度検証を行います。
9. 検証に成功したら Next をクリックします。
10. Connection Name フィールドに、このコネクションを別のコネクションと区別するために使用する名前を入力します。たとえば、Obtain S3 Data を入力します。
11. Description は任意のフィールドで、このコネクションに関する便利な情報を入力します。たとえば、Sample S3 connection that obtains data from the northeast bucket. を入力します。
12. 右上にある Create をクリックし、作成したコネクションが利用可能になったことを確認します。上記の例の名前を入力した場合は、インテグレーションに追加できるコネクションとして Obtain S3 Data が表示されます。

手順

1. Fuse Online パネルの左側にある Integrations をクリックします。
2. Create Integration をクリックします。
3. Choose a Start Connection ページで、インテグレーションを開始するために使用する Amazon S3 コネクションをクリックします。

4. Choose an Action ページで、コネクションが実行するアクションをクリックします。

   • Get Object は、コネクションがアクセスするバケットからファイルを取得します。File Name フィールドでは、取得するファイルの名前を入力します。指定したファイルがバケットにない場合は、ランタイムエラーが発生します。

   • Poll an Amazon S3 Bucket は、コネクションがアクセスするバケットからファイルを定期的に取得します。このアクションを設定するには、以下を行います。

     1. Delay フィールドで、デフォルトの 500 ミリ秒をポーリング間の経過時間として受け入れます。別のポーリング間隔を指定する場合は、数値を入力し、時間の単位を選択します。

     2. Maximum Objects to Retrieve フィールドに、1 回のポーリング操作で取得可能なファイルの最大数を入力します。デフォルトは 10 です。

        取得するファイルの数を無制限にするには、0 または負の整数を指定します。Maximum Objects to Retrieve が無制限の場合、ポーリングはバケットのすべてのファイルを取得します。

        バケットに指定された最大数を超える数のファイルが含まれている場合、編集または作成日時が最も新しいファイルから取得します。

     3. Prefix フィールドには、文字列を評価する正規表現を任意で指定します。接頭辞を指定した場合、名前がこの文字列で始まるファイルのみを取得します。
     4. Obtain files and then delete them from the bucket (ファイルを取得し、取得済みのファイルをバケットから削除) を行うかどうかを示します。
5. アクションの設定後、Done をクリックしてアクションの出力タイプを指定します。

6. データタイプの認識が必要がない場合は、Select Type フィールドで Type specification not required を受け入れ、下部にある Done をクリックします。残りの手順を行う必要はありません。

   その他の場合は、以下の 1 つをスキーマタイプとして選択します。

   • JSON schema は JSON データの構造を記述するドキュメントです。ドキュメントのメディアタイプは application/schema+json です。
   • JSON instance は JSON データが含まれるドキュメントです。ドキュメントのメディアタイプは application/json です。
   • XML schema は XML データの構造を記述するドキュメントです。このドキュメントのファイル拡張子は .xsd です。
   • XML instance は XML データが含まれるドキュメントです。このドキュメントのファイル拡張子は .xml です。
7. Definition 入力ボックスに、選択したスキーマタイプに準拠する定義を貼り付けます。たとえば、JSON schema を選択した場合は、メディアタイプが application/schema+json の JSON スキーマファイルの内容を貼り付けます。

8. Data Type Name フィールドにはデータタイプに選択した名前を入力します。たとえば、ベンダーの JSON スキーマを指定する場合は、データ型名として Vendor を指定できます。

   このタイプを指定するコネクションを使用するインテグレーションを作成または編集するときにこのデータタイプ名が表示されます。Fuse Online では、インテグレーション仮想化パネルとデータマッパーにタイプ名が表示されます。

9. Data Type Description フィールドには、このタイプを区別するのに便利な情報を提供します。データマッパーでこのタイプを処理するステップにカーソルを合わせると、この説明が表示されます。
10. Done をクリックします。

手順

1. インテグレーションの作成を開始します。
2. 最初のコネクションを追加および設定します。
3. Choose a Finish Connection ページで、インテグレーションの終了に使用する Amazon S3 コネクションをクリックします。

4. コネクションが実行するアクションをクリックします。

   • Copy Object は 1 つ以上のオブジェクトをバケットに追加します。

     1 つのファイルをバケットに追加するには、その名前を File Name フィールドに入力します。

     複数のファイルをバケットに追加する場合はファイル名を指定しません。この場合、アクションによって以前のインテグレーションステップから取得されるすべてのオブジェクトが追加されます。

     ポーリングを使用して複数のファイルを取得し、ファイル名を指定する場合、Copy Object アクションはポーリングで受け取った最後のファイルのみを追加します。

   • Delete Object はバケットからオブジェクトを削除します。File Name フィールドに削除するオブジェクトの名前を指定します。指定したファイルがバケットにない場合、エラーは発生せず、インテグレーションが継続されます。
5. 指定したアクションの設定後、Next をクリックしてアクションの入力タイプを指定します。

6. データタイプの認識が必要がない場合は、Select Type フィールドで Type specification not required を受け入れ、下部にある Done をクリックします。残りの手順を行う必要はありません。

   その他の場合は、以下の 1 つをスキーマタイプとして選択します。

   • JSON schema は JSON データの構造を記述するドキュメントです。ドキュメントのメディアタイプは application/schema+json です。
   • JSON instance は JSON データが含まれるドキュメントです。ドキュメントのメディアタイプは application/json です。
   • XML schema は XML データの構造を記述するドキュメントです。このドキュメントのファイル拡張子は .xsd です。
   • XML instance は XML データが含まれるドキュメントです。このドキュメントのファイル拡張子は .xml です。
7. Definition 入力ボックスに、選択したスキーマタイプに準拠する定義を貼り付けます。たとえば、JSON schema を選択した場合は、メディアタイプが application/schema+json の JSON スキーマファイルの内容を貼り付けます。

8. Data Type Name フィールドにはデータタイプに選択した名前を入力します。たとえば、ベンダーの JSON スキーマを指定する場合は、データ型名として Vendor を指定できます。

   このタイプを指定するコネクションを使用するインテグレーションを作成または編集するときにこのデータタイプ名が表示されます。Fuse Online では、インテグレーション仮想化パネルとデータマッパーにタイプ名が表示されます。

9. Data Type Description フィールドには、このタイプを区別するのに便利な情報を提供します。データマッパーでこのタイプを処理するステップにカーソルを合わせると、この説明が表示されます。
10. Done をクリックします。

手順

1. フローの途中に使用する Amazon S3 コネクションをクリックします。

2. コネクションが実行するアクションをクリックします。

   • Copy Object は 1 つ以上のオブジェクトをバケットに追加します。

     1 つのファイルをバケットに追加するには、その名前を File Name フィールドに入力します。

     複数のファイルをバケットに追加する場合はファイル名を指定しません。この場合、アクションによって以前のインテグレーションステップから取得されるすべてのオブジェクトが追加されます。

     ポーリングを使用して複数のファイルを取得し、ファイル名を指定する場合、Copy Object アクションはポーリングで受け取った最後のファイルのみを追加します。

   • Delete Object はバケットからオブジェクトを削除します。File Name フィールドに削除するオブジェクトの名前を指定します。指定したファイルがバケットにない場合、エラーは発生せず、インテグレーションが継続されます。
3. 指定したアクションの設定後、Next をクリックしてアクションの入力タイプを指定します。

4. データタイプの認識が必要がない場合は、Select Type フィールドで Type specification not required を受け入れ、下部にある Done をクリックします。残りの手順を行う必要はありません。

   その他の場合は、以下の 1 つをスキーマタイプとして選択します。

   • JSON schema は JSON データの構造を記述するドキュメントです。ドキュメントのメディアタイプは application/schema+json です。
   • JSON instance は JSON データが含まれるドキュメントです。ドキュメントのメディアタイプは application/json です。
   • XML schema は XML データの構造を記述するドキュメントです。このドキュメントのファイル拡張子は .xsd です。
   • XML instance は XML データが含まれるドキュメントです。このドキュメントのファイル拡張子は .xml です。
5. Definition 入力ボックスに、選択したスキーマタイプに準拠する定義を貼り付けます。たとえば、JSON schema を選択した場合は、メディアタイプが application/schema+json の JSON スキーマファイルの内容を貼り付けます。

6. Data Type Name フィールドにはデータタイプに選択した名前を入力します。たとえば、ベンダーの JSON スキーマを指定する場合は、データ型名として Vendor を指定できます。

   このタイプを指定するコネクションを使用するインテグレーションを作成または編集するときにこのデータタイプ名が表示されます。Fuse Online では、インテグレーション仮想化パネルとデータマッパーにタイプ名が表示されます。

7. Data Type Description フィールドには、このタイプを区別するのに便利な情報を提供します。データマッパーでこのタイプを処理するステップにカーソルを合わせると、この説明が表示されます。
8. Done をクリックします。