forked from GoogleCloudPlatform/python-docs-samples
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathimage.py
More file actions
91 lines (68 loc) · 3.02 KB
/
Copy pathimage.py
File metadata and controls
91 lines (68 loc) · 3.02 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
# Copyright 2018 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the 'License');
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an 'AS IS' BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
# [START run_imageproc_handler_setup]
import os
import tempfile
from google.cloud import storage, vision
from wand.image import Image
storage_client = storage.Client()
vision_client = vision.ImageAnnotatorClient()
# [END run_imageproc_handler_setup]
# [START run_imageproc_handler_analyze]
# Blurs uploaded images that are flagged as Adult or Violence.
def blur_offensive_images(data):
file_data = data
file_name = file_data["name"]
bucket_name = file_data["bucket"]
blob = storage_client.bucket(bucket_name).get_blob(file_name)
blob_uri = f"gs://{bucket_name}/{file_name}"
blob_source = vision.Image(source=vision.ImageSource(image_uri=blob_uri))
# Ignore already-blurred files
if file_name.startswith("blurred-"):
print(f"The image {file_name} is already blurred.")
return
print(f"Analyzing {file_name}.")
result = vision_client.safe_search_detection(image=blob_source)
detected = result.safe_search_annotation
# Process image
if detected.adult == 5 or detected.violence == 5:
print(f"The image {file_name} was detected as inappropriate.")
return __blur_image(blob)
else:
print(f"The image {file_name} was detected as OK.")
# [END run_imageproc_handler_analyze]
# [START run_imageproc_handler_blur]
# Blurs the given file using ImageMagick.
def __blur_image(current_blob):
file_name = current_blob.name
_, temp_local_filename = tempfile.mkstemp()
# Download file from bucket.
current_blob.download_to_filename(temp_local_filename)
print(f"Image {file_name} was downloaded to {temp_local_filename}.")
# Blur the image using ImageMagick.
with Image(filename=temp_local_filename) as image:
image.resize(*image.size, blur=16, filter="hamming")
image.save(filename=temp_local_filename)
print(f"Image {file_name} was blurred.")
# Upload result to a second bucket, to avoid re-triggering the function.
# You could instead re-upload it to the same bucket + tell your function
# to ignore files marked as blurred (e.g. those with a "blurred" prefix)
blur_bucket_name = os.getenv("BLURRED_BUCKET_NAME")
blur_bucket = storage_client.bucket(blur_bucket_name)
new_blob = blur_bucket.blob(file_name)
new_blob.upload_from_filename(temp_local_filename)
print(f"Blurred image uploaded to: gs://{blur_bucket_name}/{file_name}")
# Delete the temporary file.
os.remove(temp_local_filename)
# [END run_imageproc_handler_blur]