Как аннотировать НЕСКОЛЬКО изображений из одного вызова с помощью Google API видения? питон - PullRequest
Новая
       16

Как аннотировать НЕСКОЛЬКО изображений из одного вызова с помощью Google API видения? питон

1 голос
/ 06 ноября 2019

Я недавно начал использовать API видения Google. Я пытаюсь комментировать партию изображений и поэтому выпустил руководство 'автономная аннотация партий изображений' из их документации.

Однако мне не ясно, как я могу комментировать НЕСКОЛЬКО изображений из одного вызова API. Допустим, я сохранил 10 изображений в моем облачном хранилище Google. Как я могу аннотировать все эти изображения одновременно и хранить их в одном файле JSON? Прямо сейчас я написал программу, которая вызывает их примерную функцию, и она работает, но, проще говоря, почему я не могу сказать: «Посмотрите в эту папку и аннотируйте все изображения в ней.»?

Спасибозаранее. 

from batch_image_labeling import sample_async_batch_annotate_images
counter = 0
for file in os.listdir('my_directory'):
    filename = file
    sample_async_batch_annotate_images('gs://my_bucket/{}'.format(filename), 'gs://my_bucket/{}'.format(counter))
    counter += 1


from google.cloud import vision_v1
from google.cloud.vision_v1 import enums
import six

def sample_async_batch_annotate_images(input_image_uri, output_uri):
  """Perform async batch image annotation"""

  client = vision_v1.ImageAnnotatorClient()

  if isinstance(input_image_uri, six.binary_type):
    input_image_uri = input_image_uri.decode('utf-8')
  if isinstance(output_uri, six.binary_type):
    output_uri = output_uri.decode('utf-8')
  source = {'image_uri': input_image_uri}
  image = {'source': source}
  type_ = enums.Feature.Type.LABEL_DETECTION
  features_element = {'type': type_}
  type_2 = enums.Feature.Type.IMAGE_PROPERTIES
  features_element_2 = {'type': type_2}
  features = [features_element, features_element_2]
  requests_element = {'image': image, 'features': features}
  requests = [requests_element]
  gcs_destination = {'uri': output_uri}

  # The max number of responses to output in each JSON file
  batch_size = 2
  output_config = {'gcs_destination': gcs_destination, 'batch_size': batch_size}

  operation = client.async_batch_annotate_images(requests, output_config)

  print('Waiting for operation to complete...')
  response = operation.result()

  # The output is written to GCS with the provided output_uri as prefix
  gcs_output_uri = response.output_config.gcs_destination.uri
  print('Output written to GCS with prefix: {}'.format(gcs_output_uri))

1 Ответ

0 голосов
/ 06 ноября 2019

Это не совсем понятно из этого примера, но ваш вызов async_batch_annotate_images принимает параметр requests, который представляет собой список из нескольких запросов. Таким образом, вы можете сделать что-то вроде этого: 

rom google.cloud import vision_v1
from google.cloud.vision_v1 import enums
import six

def generate_request(input_image_uri):
  if isinstance(input_image_uri, six.binary_type):
    input_image_uri = input_image_uri.decode('utf-8')
  if isinstance(output_uri, six.binary_type):
    output_uri = output_uri.decode('utf-8')
  source = {'image_uri': input_image_uri}
  image = {'source': source}
  type_ = enums.Feature.Type.LABEL_DETECTION
  features_element = {'type': type_}
  type_2 = enums.Feature.Type.IMAGE_PROPERTIES
  features_element_2 = {'type': type_2}
  features = [features_element, features_element_2]
  requests_element = {'image': image, 'features': features}

  return requests_element


def sample_async_batch_annotate_images(input_uri, output_uri):
  """Perform async batch image annotation"""

  client = vision_v1.ImageAnnotatorClient()

  requests = [
    generate_request(input_uri.format(filename))
    for filename in os.listdir('my_directory')
  ]

  gcs_destination = {'uri': output_uri}

  # The max number of responses to output in each JSON file
  batch_size = 1
  output_config = {'gcs_destination': gcs_destination, 'batch_size': batch_size}

  operation = client.async_batch_annotate_images(requests, output_config)

  print('Waiting for operation to complete...')
  response = operation.result()

  # The output is written to GCS with the provided output_uri as prefix
  gcs_output_uri = response.output_config.gcs_destination.uri
  print('Output written to GCS with prefix: {}'.format(gcs_output_uri))


sample_async_batch_annotate_images('gs://my_bucket/{}', 'gs://my_bucket/results')

Это может аннотировать до 2000 изображений за один запрос. Единственным недостатком является то, что вы можете указать только один output_uri в качестве места назначения, поэтому вы не сможете использовать counter, чтобы поместить каждый результат в отдельный файл, но вы можете установить batch_size = 1, чтобы обеспечить каждый ответнаписано отдельно, если это то, что вы хотите.

...