code: def process_account(account_info):
      
      log = logging.getLogger('salactus.bucket-iterator')
      log.info("processing account %s", account_info)
      session = get_session(account_info)
      client = session.client('s3', config=s3config)
      buckets = client.list_buckets()['Buckets']
  
      connection.hset(
          'bucket-accounts', account_info['name'], json.dumps(account_info))
  
      for b in buckets:
          connection.hset(
              'bucket-ages', bucket_id(account_info, b['Name']),
              b['CreationDate'].isoformat())
  
      account_buckets = account_info.pop('buckets', None)
      buckets = [n['Name'] for n in buckets
                 if not account_buckets or
                 n['Name'] in account_buckets]
      account_not_buckets = account_info.pop('not-buckets', None)
      buckets = [n for n in buckets
                 if not account_not_buckets or
                 n not in account_not_buckets]
      log.info("processing %d buckets in account %s",
               len(buckets), account_info['name'])
      for bucket_set in chunks(buckets, 50):
          invoke(process_bucket_set, account_info, bucket_set)
docs: Scan all buckets in an account and schedule processing