feat: Add encryption_key param to Blob.from_string

google/cloud/storage/blob.py

@@ -344,36 +344,41 @@ def public_url(self):
         )
 
     @classmethod
-    def from_string(cls, uri, client=None):
+    def from_string(cls, uri, client=None, encryption_key=None):
         """Get a constructor for blob object by URI.
 
-         :type uri: str
-         :param uri: The blob uri pass to get blob object.
+        :type uri: str
+        :param uri: The blob uri pass to get blob object.
 
         :type client: :class:`~google.cloud.storage.client.Client`
         :param client:
             (Optional) The client to use.  If not passed, falls back to the
             ``client`` stored on the blob's bucket.
+
+        :type encryption_key: bytes
+        :param encryption_key:
+            (Optional) 32 byte encryption key for customer-supplied encryption.
+            See https://cloud.google.com/storage/docs/encryption#customer-supplied.
 
-         :rtype: :class:`google.cloud.storage.blob.Blob`
-         :returns: The blob object created.
+        :rtype: :class:`google.cloud.storage.blob.Blob`
+        :returns: The blob object created.
 
-         Example:
-            Get a constructor for blob object by URI..
+        Example:
+            Get a constructor for blob object by URI.
 
             >>> from google.cloud import storage
             >>> from google.cloud.storage.blob import Blob
             >>> client = storage.Client()
             >>> blob = Blob.from_string("gs://bucket/object")
-         """
+        """
         from google.cloud.storage.bucket import Bucket
 
         scheme, netloc, path, query, frag = urlsplit(uri)
         if scheme != "gs":
             raise ValueError("URI scheme must be gs")
 
         bucket = Bucket(client, name=netloc)
-        return cls(path[1:], bucket)
+        return cls(path[1:], bucket, encryption_key=encryption_key)
 
     def generate_signed_url(
         self,

tests/unit/test_blob.py

@@ -4673,6 +4673,19 @@ def test_from_string_w_domain_name_bucket(self):
         self.assertEqual(blob.name, "b")
         self.assertEqual(blob.bucket.name, "buckets.example.com")
 
+    def test_from_string_w_encryption_key(self):
+        from google.cloud.storage.blob import Blob
+
+        connection = _Connection()
+        client = _Client(connection)
+        uri = "gs://bucket-name/blob-name"
+        encryption_key = b"0123456789abcdef0123456789abcdef"
+        blob = Blob.from_string(uri, client, encryption_key=encryption_key)
+
+        self.assertIsInstance(blob, Blob)
+        self.assertIs(blob.client, client)
+        self.assertEqual(blob._encryption_key, encryption_key)
+
     def test_open(self):
         from io import TextIOWrapper
         from google.cloud.storage.fileio import BlobReader