d1c53afd1bf7d5989684e585c324160bd80bbd39,perfkitbenchmarker/scripts/object_storage_api_test_scripts/s3.py,S3Service,WriteObjectFromBuffer,#S3Service#Any#Any#Any#Any#,35

Before Change

    // We need to access the raw key object so we can set its storage
    // class
    key = object_uri.new_key()
    if FLAGS.object_storage_class is not None:
      key._set_storage_class(FLAGS.object_storage_class)  // pylint:disable=protected-access
    key.set_contents_from_file(stream, size=size)
    latency = time.time() - start_time
    return start_time, latency

After Change

  def WriteObjectFromBuffer(self, bucket, object_name, stream, size):
    start_time = time.time()
    stream.seek(0)
    obj = six.BytesIO(stream.read(size))
    self.client.put_object(Body=obj, Bucket=bucket, Key=object_name)
    latency = time.time() - start_time
    return start_time, latency

Instances