def query_oss_risk_item()

in solution/finance/storage_risk_item.py [0:0]

• 37 lines of code
• 10 McCabe index (conditional complexity)

    def query_oss_risk_item(account_id,
                            access_key_id,
                            access_key_secret,
                            role_name):

        # for region_id in region_id_list:
        client = StorageResourceSample.create_oss_client(account_id,
                                                         access_key_id,
                                                         access_key_secret,
                                                         role_name,
                                                         'cn-shanghai')

        buckets = StorageResourceSample.query_oss_bucket_list(client)

        for bucket in buckets:
            bucket_region = bucket['Region']
            bucket_name = bucket['Name']
            client = StorageResourceSample.create_oss_client(account_id,
                                                             access_key_id,
                                                             access_key_secret,
                                                             role_name,
                                                             bucket_region)

            output_str = f'AccountId: {account_id} Region:{bucket_region}\n'
            try:
                resp = client.get_bucket_lifecycle(bucket_name)
                # print(resp.to_map()['body'])
                rules = resp.to_map()['body']['Rule']
                if rules is not list:
                    rules = [rules]
                exist_enable_rule = False
                for rule in rules:
                    if rule['Status'] == 'Enable':
                        exist_enable_rule = True
                        break
                if not exist_enable_rule:
                    output_str += f'<Bucket:{bucket_name} Info:无启用的生命周期规则>\n'

            except TeaException as error:
                if error.code == 'NoSuchLifecycle':
                    output_str += f'<Bucket:{bucket_name} Info:无生命周期规则>\n'
                # print(error)
            except Exception as error:
                print(repr(error))
            print(output_str)