Oracle Cloud データの Cost Management への統合

手順

1. Red Hat Hybrid Cloud Console から、Settings Menu > Integrations をクリックします。
2. Settings ページで、Integrations をクリックします。
3. Cloud タブで、Add integration をクリックします。
4. Add a cloud integration ウィザードで、統合タイプとして Oracle Cloud Infrastructure を選択します。Next をクリックします。
5. インテグレーションの名前を入力し、Next をクリックします。
6. Select application の手順で、Cost Management を選択します。Next をクリックします。

手順

1. Add a cloud integration ウィザードの Global compartment-id ステップでステップ 1 oci iam compartment list のコマンドをコピーします。
2. 新しいタブで、Oracle Cloud アカウントにログインします。
3. メニューバーで、Developer tools > Cloud Shell をクリックします。
4. Add a cloud integration ウィザードからコピーしたコマンドを Cloud Shell ウィンドウに貼り付けます。

5. 応答で、compartment-id キーの値のペアをコピーします。以下の例では、ID は ocid1.tenancy.oc1 で始まります。

   応答の例

   {
     "data": [
       {
         "compartment-id": "ocid1.tenancy.oc1..00000000000000000000000000000000000000000000",
         "defined-tags": {
           "Oracle-Tags": {
               ...
           }
         },
         ...
       }
     ]
   }

6. Add a cloud integration の Global compartment-id ステップに戻り、Global compartment-id フィールドに tenant-id を貼り付けます。
7. Next をクリックします。

手順

1. Add a cloud integration ウィザードの Create new policy and compartment ページで、oci iam policy create コマンドをコピーします。
2. コピーしたコマンドを Oracle Cloud タブの Cloud Shell に貼り付けて、コストおよび使用状況レポートのポリシーを作成します。ポリシーの説明を追加することもできます。
3. Add a cloud integration ウィザードの Create new policy and compartment ステップに戻り、oci iam compartment create コマンドをコピーします。
4. コピーしたコマンドを Oracle Cloud タブの Cloud Shell に貼り付けて、Cost Management コンパートメントを作成します。

5. 応答で、id キーの値をコピーします。次の例では、ocid1.compartment.oc1 を含む ID をコピーします。

   応答の例

   {
     "data": [
       {
         "compartment-id": "tenant-id",
         "defined-tags": {
           "Oracle-Tags": {
               ...
           }
         },
         "description": "Cost management compartment for cost and usage data",
         "freeform-tags": {},
         "id": "ocid1.compartment.oc1..0000000000000000000000000000000000000000000",
         ...
       },
       ...
     ]
   }

6. Add a cloud integration ウィザードの Create new policy and compartment ステップに戻り、最後のステップの応答からコピーした ID 値を New compartment-id フィールドに貼り付けます。
7. Next をクリックします。

手順

1. Create bucket ステップで、Cost Management がアクセスできるように、コストおよび使用状況データを保存するバケットを作成します。

2. 前の手順でコマンドをコピーし、Oracle Cloud タブの Cloud Shell に貼り付けて、バケットを作成します。次の手順は、応答例を参照してください。

   応答の例

   {
     "data": {
       ...
       "name": "cost-management",
       "namespace": "cost-management-namespace",
   
       ...
       }
   }

3. name キーの値のペアをコピーします。前の例では、この値は cost-management です。
4. Add a cloud integration ウィザードの Create bucket ステップに戻ります。コピーした値を New data bucket name に貼り付けます。
5. Cloud Shell に戻り、namespace キーの値をコピーします。前の例では、cost-management-namespace をコピーします。
6. Add a cloud integration ウィザードの Create bucket ステップに戻り、リージョンのシェルプロンプトを確認します。たとえば、シェルプロンプトは、user@cloudshell:~ (uk-london-1)$ のようになります。この例では、uk-london-1 がリージョンです。リージョンをコピーし、Add a cloud integration ウィザードの Create bucket のステップに戻ります。
7. Add a cloud integration ウィザードの Create bucket 手順で、New bucket region にリージョンを貼り付けます。
8. Next をクリックします。

手順

1. Oracle Cloud コンソール で、ナビゲーションメニューを開いて、Developer Services > Functions をクリックします。

2. 次の Python スクリプトを使用して、ファンクションアプリケーションを作成します。

   #
   # Copyright 2022 Red Hat Inc.
   # SPDX-License-Identifier: Apache-2.0
   #
   ##########################################################################################
   # Script to collect cost/usage reports from OCI and replicate them to another bucket
   #
   # Pre-req's you must have a service account or other for this script to gain access to oci
   #
   # NOTE! You must update the vars below for this script to work correctly
   #
   # user: ocid of user that has correct permissions for bucket objects
   # key_file: Location of auth file for defind user
   # fingerprint: Users fingerprint
   # tenancy: Tenancy for collecting/copying cost/usage reports
   # region: Home Region of your tenancy
   # bucket: Name of Bucket reports will be replicated to
   # namespace: Object Storage Namespace
   # filename: Name of json file to store last report downloaded default hre is fine
   ##########################################################################################
   import datetime
   import io
   import json
   import logging
   
   import oci
   from fdk import response
   
   
   def connect_oci_storage_client(config):
       # Connect to OCI SDK
       try:
           object_storage = oci.object_storage.ObjectStorageClient(config)
           return object_storage
       except (Exception, ValueError) as ex:
           logging.getLogger().info("Error connecting to OCI SDK CLIENT please check credentials: " + str(ex))
   
   
   def fetch_reports_file(object_storage, namespace, bucket, filename):
       # Fetch last download report file from bucket
       last_reports_file = None
       try:
           last_reports_file = object_storage.get_object(namespace, bucket, filename)
       except (Exception, ValueError) as ex:
           logging.getLogger().info("Object file does not exist, will attempt to create it: " + str(ex))
   
       if last_reports_file:
           json_acceptable_string = last_reports_file.data.text.replace("'", '"')
           try:
               last_reports = json.loads(json_acceptable_string)
           except (Exception, ValueError) as ex:
               logging.getLogger().info(
                   "Json string file not formatted correctly and cannont be parsed, creating fresh file. " + str(ex)
               )
               last_reports = {"cost": "", "usage": ""}
       else:
           last_reports = {"cost": "", "usage": ""}
   
       return last_reports
   
   
   def get_report_list(object_storage, reporting_namespace, reporting_bucket, prefix, last_file):
       # Create a list of reports
       report_list = object_storage.list_objects(
           reporting_namespace, reporting_bucket, prefix=prefix, start_after=last_file, fields="timeCreated"
       )
       logging.getLogger().info("Fetching list of cost csv files")
       return report_list
   
   
   def copy_reports_to_bucket(
       object_storage,
       report_type,
       report_list,
       bucket,
       namespace,
       region,
       reporting_namespace,
       reporting_bucket,
       last_reports,
   ):
       # Iterate through cost reports list and copy them to new bucket
       # Start from current month
       start_from = datetime.date.today().replace(day=1)
   
       if report_list.data.objects != []:
           for report in report_list.data.objects:
               if report.time_created.date() > start_from:
                   try:
                       copy_object_details = oci.object_storage.models.CopyObjectDetails(
                           destination_bucket=bucket,
                           destination_namespace=namespace,
                           destination_object_name=report.name,
                           destination_region=region,
                           source_object_name=report.name,
                       )
                       object_storage.copy_object(
                           namespace_name=reporting_namespace,
                           bucket_name=reporting_bucket,
                           copy_object_details=copy_object_details,
                       )
                   except (Exception, ValueError) as ex:
                       logging.getLogger().info(f"Failed to copy {report.name} to bucket: {bucket}. " + str(ex))
           last_reports[report_type] = report.name
       else:
           logging.getLogger().info(f"No new {report_type} reports to copy to bucket: {bucket}.")
       return last_reports
   
   
   def handler(ctx, data: io.BytesIO = None):
       name = "OCI-cost-mgmt-report-replication-function"
       try:
           body = json.loads(data.getvalue())
           name = body.get("name")
       except (Exception, ValueError) as ex:
           logging.getLogger().info("Error parsing json payload: " + str(ex))
   
       logging.getLogger().info("Inside Python OCI reporting copy function")
   
       # PLEASE CHANGE THIS!!!! #
       user = "ocid1.user.oc1..aaaaaa"  # CHANGEME
       key_file = "auth_files/service-account.pem"  # CHANGEME
       fingerprint = "00.00.00"  # CHANGEME
       tenancy = "ocid1.tenancy.oc1..aaaaaaa"  # CHANGEME
       region = "region"  # CHANGEME
       bucket = "cost-mgmt-bucket"  # CHANGEME
       namespace = "namespace"  # CHANGEME
       filename = "last_reports.json"
   
       # Get the list of reports
       # https://docs.oracle.com/en-us/iaas/Content/API/SDKDocs/clienvironmentvariables.htm!!!
       config = {
           "user": user,
           "key_file": key_file,
           "fingerprint": fingerprint,
           "tenancy": tenancy,
           "region": region,
       }
       # The Object Storage namespace used for OCI reports is bling; the bucket name is the tenancy OCID.
       reporting_namespace = "bling"
       reporting_bucket = config["tenancy"]
       region = config["region"]
   
       # Connect to OCI
       object_storage = connect_oci_storage_client(config)
   
       # Grab reports json and set previously downloaded file values
       last_reports = fetch_reports_file(object_storage, namespace, bucket, filename)
       last_cost_file = last_reports.get("cost")
       last_usage_file = last_reports.get("usage")
   
       # Get list of cost/usage files
       cost_report_list = get_report_list(
           object_storage, reporting_namespace, reporting_bucket, "reports/cost-csv", last_cost_file
       )
       usage_report_list = get_report_list(
           object_storage, reporting_namespace, reporting_bucket, "reports/usage-csv", last_usage_file
       )
   
       # Copy cost/usage files to new bucket
       last_reports = copy_reports_to_bucket(
           object_storage,
           "cost",
           cost_report_list,
           bucket,
           namespace,
           region,
           reporting_namespace,
           reporting_bucket,
           last_reports,
       )
       last_reports = copy_reports_to_bucket(
           object_storage,
           "usage",
           usage_report_list,
           bucket,
           namespace,
           region,
           reporting_namespace,
           reporting_bucket,
           last_reports,
       )
   
       # Save updated filenames to bucket object as string
       object_storage.put_object(namespace, bucket, filename, str(last_reports))
   
       return response.Response(
           ctx,
           response_data=json.dumps(
               {
                   "message": "Last reports saved from {}, Cost: {}, Usage: {}".format(
                       name, last_reports["cost"], last_reports["usage"]
                   )
               }
           ),
           headers={"Content-Type": "application/json"},
       )

3. # CHANGEME とマークされた値を環境の値に変更します。

   user = "ocid1.user.oc1..aaaaaa"  # CHANGEME
   key_file = "auth_files/service-account.pem"  # CHANGEME
   fingerprint = "00.00.00"  # CHANGEME
   tenancy = "ocid1.tenancy.oc1..aaaaaaa"  # CHANGEME
   region = "region"  # CHANGEME
   bucket = "cost-mgmt-bucket"  # CHANGEME
   namespace = "namespace"  # CHANGEME
   filename = "last_reports.json"

4. 仮想マシンまたは Kubernetes CronJob を作成して、ファンクションを毎日トリガーします。

手順

1. Populate bucket ステップで、oci iam policy create コマンドをコピーし、Oracle Cloud タブの Cloud Shell に貼り付けて、読み取りポリシーを作成します。
2. Next をクリックします。
3. 提供した情報の詳細を確認します。Add をクリックします。