Idiomatic Ruby client for Google Cloud Platform services.
This client supports the following Google Cloud Platform services:
- Cloud Asset
- Cloud AutoML API
- BigQuery
- BigQuery Data Transfer
- Cloud Bigtable
- Cloud Billing API
- Container Analysis
- Container Engine
- Cloud Dataproc
- Cloud Datastore
- Stackdriver Debugger
- Dialogflow API
- Data Loss Prevention
- Cloud DNS
- Stackdriver Error Reporting
- Cloud Firestore
- Cloud Key Management Service
- Cloud Natural Language API
- Stackdriver Logging
- Stackdriver Monitoring API
- Cloud OS Login
- Phishing Protection
- Cloud Pub/Sub
- Recaptcha Enterprise
- Cloud Recommender API
- Cloud Redis
- Cloud Resource Manager
- Cloud Scheduler
- Secret Manager API
- Cloud Security Center
- Cloud Spanner API
- Cloud Speech API
- Cloud Storage
- Cloud Talent Solutions API
- Cloud Tasks API
- Cloud Text-To-Speech API
- Stackdriver Trace
- Cloud Translation API
- Cloud Video Intelligence API
- Cloud Vision API
- Web Risk API
The support for each service is distributed as a separate gem. However, for your
convenience, the google-cloud
gem lets you install the entire collection.
If you need support for other Google APIs, check out the Google API Ruby Client library.
$ gem install google-cloud
The google-cloud
gem shown above provides all of the individual service gems
in the google-cloud-ruby project, making it easy to explore Google Cloud
Platform. To avoid unnecessary dependencies, you can also install the service
gems independently.
In general, the google-cloud-ruby library uses Service Account credentials to connect to Google Cloud services. When running on Google Cloud Platform (GCP), including Google Compute Engine (GCE), Google Kubernetes Engine (GKE), Google App Engine (GAE), Google Cloud Functions (GCF) and Cloud Run, the credentials will be discovered automatically. When running on other environments, the Service Account credentials can be specified by providing the path to the JSON keyfile for the account (or the JSON itself) in environment variables. Additionally, Cloud SDK credentials can also be discovered automatically, but this is only recommended during development.
General instructions, environment variables, and configuration options are
covered in the general Authentication
guide
for the google-cloud
umbrella package. Specific instructions and environment
variables for each individual service are linked from the README documents
listed below for each service.
The preview examples below demonstrate how to provide the Project ID and Credentials JSON file path directly in code.
$ gem install google-cloud-asset
$ gem install google-cloud-automl
- google-cloud-bigquery README
- google-cloud-bigquery API documentation
- google-cloud-bigquery on RubyGems
- Google BigQuery documentation
$ gem install google-cloud-bigquery
require "google/cloud/bigquery"
bigquery = Google::Cloud::Bigquery.new
dataset = bigquery.create_dataset "my_dataset"
table = dataset.create_table "my_table" do |t|
t.name = "My Table"
t.description = "A description of my table."
t.schema do |s|
s.string "first_name", mode: :required
s.string "last_name", mode: :required
s.integer "age", mode: :required
end
end
# Load data into the table from Google Cloud Storage
table.load "gs://my-bucket/file-name.csv"
# Run a query
data = dataset.query "SELECT first_name FROM my_table"
data.each do |row|
puts row[:first_name]
end
- google-bigquery-data_transfer README
- google-bigquery-data_transfer API documentation
- google-bigquery-data_transfer on RubyGems
- Google BigQuery Data Transfer documentation
$ gem install google-cloud-bigquery-data_transfer
require "google/cloud/bigquery/data_transfer"
data_transfer_service_client = Google::Cloud::Bigquery::DataTransfer.new
formatted_parent = Google::Cloud::Bigquery::DataTransfer::V1::DataTransferServiceClient.project_path(project_id)
# Iterate over all results.
data_transfer_service_client.list_data_sources(formatted_parent).each do |element|
# Process element.
end
# Or iterate over results one page at a time.
data_transfer_service_client.list_data_sources(formatted_parent).each_page do |page|
# Process each page at a time.
page.each do |element|
# Process element.
end
end
- google-cloud-bigtable README
- google-cloud-bigtable API documentation
- google-cloud-bigtable on RubyGems
- Cloud Bigtable documentation
$ gem install google-cloud-bigtable
require "google/cloud/bigtable"
bigtable = Google::Cloud::Bigtable.new
table = bigtable.table("my-instance", "my-table")
entry = table.new_mutation_entry("user-1")
entry.set_cell(
"cf-1",
"field-1",
"XYZ",
timestamp: Time.now.to_i * 1000 # Time stamp in milli seconds.
).delete_cells("cf2", "field02")
table.mutate_row(entry)
$ gem install google-cloud-billing
- google-cloud-datastore README
- google-cloud-datastore API documentation
- google-cloud-datastore on RubyGems
- Google Cloud Datastore documentation
Follow the activation instructions to use the Google Cloud Datastore API with your project.
$ gem install google-cloud-datastore
require "google/cloud/datastore"
datastore = Google::Cloud::Datastore.new(
project_id: "my-todo-project",
credentials: "/path/to/keyfile.json"
)
# Create a new task to demo datastore
task = datastore.entity "Task", "sampleTask" do |t|
t["type"] = "Personal"
t["done"] = false
t["priority"] = 4
t["description"] = "Learn Cloud Datastore"
end
# Save the new task
datastore.save task
# Run a query for all completed tasks
query = datastore.query("Task").
where("done", "=", false)
tasks = datastore.run query
- google-cloud-debugger README
- google-cloud-debugger instrumentation documentation
- google-cloud-debugger on RubyGems
- Stackdriver Debugger documentation
$ gem install google-cloud-debugger
require "google/cloud/debugger"
debugger = Google::Cloud::Debugger.new
debugger.start
- google-cloud-dns README
- google-cloud-dns API documentation
- google-cloud-dns on RubyGems
- Google Cloud DNS documentation
$ gem install google-cloud-dns
require "google/cloud/dns"
dns = Google::Cloud::Dns.new
# Retrieve a zone
zone = dns.zone "example-com"
# Update records in the zone
change = zone.update do |tx|
tx.add "www", "A", 86400, "1.2.3.4"
tx.remove "example.com.", "TXT"
tx.replace "example.com.", "MX", 86400, ["10 mail1.example.com.",
"20 mail2.example.com."]
tx.modify "www.example.com.", "CNAME" do |r|
r.ttl = 86400 # only change the TTL
end
end
- google-cloud-container_analysis README
- google-cloud-container_analysis API documentation
- google-cloud-container_analysis on RubyGems
- Container Analysis documentation
$ gem install google-cloud-container_analysis
require "google/cloud/container_analysis"
container_analysis_client = Google::Cloud::ContainerAnalysis.new
grafeas_client = container_analysis_client.grafeas_client
parent = Grafeas::V1::GrafeasClient.project_path "my-project"
results = grafeas_client.list_occurrences(parent).each do |occurrence|
# do something with occurrence
end
- google-cloud-container README
- google-cloud-container API documentation
- google-cloud-container on RubyGems
- Container Engine documentation
$ gem install google-cloud-container
require "google/cloud/container"
cluster_manager_client = Google::Cloud::Container.new
project_id_2 = project_id
zone = "us-central1-a"
response = cluster_manager_client.list_clusters(project_id_2, zone)
- google-cloud-dataproc README
- google-cloud-dataproc API documentation
- google-cloud-dataproc on RubyGems
- Google Cloud Dataproc documentation
$ gem install google-cloud-dataproc
require "google/cloud/dataproc"
cluster_controller_client = Google::Cloud::Dataproc::ClusterController.new
project_id_2 = project_id
region = "global"
# Iterate over all results.
cluster_controller_client.list_clusters(project_id_2, region).each do |element|
# Process element.
end
# Or iterate over results one page at a time.
cluster_controller_client.list_clusters(project_id_2, region).each_page do |page|
# Process each page at a time.
page.each do |element|
# Process element.
end
end
- google-cloud-dlp README
- google-cloud-dlp API documentation
- google-cloud-dlp on RubyGems
- Data Loss Prevention documentation
$ gem install google-cloud-dlp
require "google/cloud/dlp"
dlp_service_client = Google::Cloud::Dlp.new
min_likelihood = :POSSIBLE
inspect_config = { min_likelihood: min_likelihood }
type = "text/plain"
value = "my phone number is 215-512-1212"
items_element = { type: type, value: value }
items = [items_element]
response = dlp_service_client.inspect_content(inspect_config, items)
- google-cloud-dialogflow README
- google-cloud-dialogflow API documentation
- google-cloud-dialogflow on RubyGems
- Dialogflow API documentation
$ gem install google-cloud-dialogflow
- google-cloud-error_reporting README
- google-cloud-error_reporting instrumentation documentation
- google-cloud-error_reporting on RubyGems
- Stackdriver Error Reporting documentation
$ gem install google-cloud-error_reporting
require "google/cloud/error_reporting"
# Report an exception
begin
fail "Boom!"
rescue => exception
Google::Cloud::ErrorReporting.report exception
end
- google-cloud-firestore README
- google-cloud-firestore API documentation
- google-cloud-firestore on RubyGems
- Google Cloud Firestore documentation
$ gem install google-cloud-firestore
require "google/cloud/firestore"
firestore = Google::Cloud::Firestore.new(
project_id: "my-project",
credentials: "/path/to/keyfile.json"
)
city = firestore.col("cities").doc("SF")
city.set({ name: "San Francisco",
state: "CA",
country: "USA",
capital: false,
population: 860000 })
firestore.transaction do |tx|
new_population = tx.get(city).data[:population] + 1
tx.update(city, { population: new_population })
end
- google-cloud-kms README
- google-cloud-kms API documentation
- google-cloud-kms on RubyGems
- Google Cloud KMS documentation
$ gem install google-cloud-kms
require "google/cloud/kms"
# Create a client for a project and given credentials
kms = Google::Cloud::Kms.new credentials: "/path/to/keyfile.json"
# Where to create key rings
key_ring_parent = kms.class.location_path "my-project", "us-central1"
# Create a new key ring
key_ring = kms.create_key_ring key_ring_parent, "my-ring", {}
puts "Created at #{Time.new key_ring.create_time.seconds}"
# Iterate over created key rings
kms.list_key_rings(key_ring_parent).each do |key_ring|
puts "Found ring called #{key_ring.name}"
end
- google-cloud-logging README
- google-cloud-logging API documentation
- google-cloud-logging on RubyGems
- Stackdriver Logging documentation
$ gem install google-cloud-logging
require "google/cloud/logging"
logging = Google::Cloud::Logging.new
# List all log entries
logging.entries.each do |e|
puts "[#{e.timestamp}] #{e.log_name} #{e.payload.inspect}"
end
# List only entries from a single log
entries = logging.entries filter: "log:syslog"
# Write a log entry
entry = logging.entry
entry.payload = "Job started."
entry.log_name = "my_app_log"
entry.resource.type = "gae_app"
entry.resource.labels[:module_id] = "1"
entry.resource.labels[:version_id] = "20150925t173233"
logging.write_entries entry
- google-cloud-language README
- google-cloud-language API documentation
- google-cloud-language on RubyGems
- Google Cloud Natural Language API documentation
$ gem install google-cloud-language
require "google/cloud/language"
language = Google::Cloud::Language.new(
project_id: "my-todo-project",
credentials: "/path/to/keyfile.json"
)
content = "Star Wars is a great movie. The Death Star is fearsome."
document = language.document content
annotation = document.annotate
annotation.entities.count #=> 3
annotation.sentiment.score #=> 0.10000000149011612
annotation.sentiment.magnitude #=> 1.100000023841858
annotation.sentences.count #=> 2
annotation.tokens.count #=> 13
- google-cloud-os_login README
- google-cloud-os_login API documentation
- google-cloud-os_login on RubyGems
- Google Cloud DNS documentation
$ gem install google-cloud-os_login
- google-cloud-phishing_protection README
- google-cloud-phishing_protection API documentation
- google-cloud-phishing_protection on RubyGems
- Phishing Protection documentation
$ gem install google-cloud-phishing_protection
- google-cloud-pubsub README
- google-cloud-pubsub API documentation
- google-cloud-pubsub on RubyGems
- Google Cloud Pub/Sub documentation
$ gem install google-cloud-pubsub
require "google/cloud/pubsub"
pubsub = Google::Cloud::Pubsub.new(
project_id: "my-todo-project",
credentials: "/path/to/keyfile.json"
)
# Retrieve a topic
topic = pubsub.topic "my-topic"
# Publish a new message
msg = topic.publish "new-message"
# Retrieve a subscription
sub = pubsub.subscription "my-topic-sub"
# Create a subscriber to listen for available messages
subscriber = sub.listen do |received_message|
# process message
received_message.acknowledge!
end
# Start background threads that will call the block passed to listen.
subscriber.start
# Shut down the subscriber when ready to stop receiving messages.
subscriber.stop.wait!
- google-cloud-recaptcha_enterprise README
- google-cloud-recaptcha_enterprise API documentation
- google-cloud-recaptcha_enterprise on RubyGems
- Recaptcha Enterprise documentation
$ gem install google-cloud-recaptcha_enterprise
- google-cloud-recommender README
- google-cloud-automl API documentation
- google-cloud-recommender on RubyGems
$ gem install google-cloud-recommender
- google-cloud-redis README
- google-cloud-redis API documentation
- google-cloud-redis on RubyGems
- Cloud Redis API documentation
$ gem install google-cloud-redis
- google-cloud-resource_manager README
- google-cloud-resource_manager API documentation
- google-cloud-resource_manager on RubyGems
- Google Cloud Resource Manager documentation
$ gem install google-cloud-resource_manager
require "google/cloud/resource_manager"
resource_manager = Google::Cloud::ResourceManager.new
# List all projects
resource_manager.projects.each do |project|
puts projects.project_id
end
# Label a project as production
project = resource_manager.project "tokyo-rain-123"
project.update do |p|
p.labels["env"] = "production"
end
# List only projects with the "production" label
projects = resource_manager.projects filter: "labels.env:production"
- google-cloud-trace README
- google-cloud-trace instrumentation documentation
- google-cloud-trace on RubyGems
- Stackdriver Trace documentation
$ gem install google-cloud-trace
require "google/cloud/trace"
trace = Google::Cloud::Trace.new
result_set = trace.list_traces Time.now - 3600, Time.now
result_set.each do |trace_record|
puts "Retrieved trace ID: #{trace_record.trace_id}"
end
- google-cloud-spanner README
- google-cloud-spanner API documentation
- google-cloud-spanner on RubyGems
- Google Cloud Spanner API documentation
$ gem install google-cloud-spanner
require "google/cloud/spanner"
spanner = Google::Cloud::Spanner.new
db = spanner.client "my-instance", "my-database"
db.transaction do |tx|
results = tx.execute "SELECT * FROM users"
results.rows.each do |row|
puts "User #{row[:id]} is #{row[:name]}"
end
end
- google-cloud-speech README
- google-cloud-speech API documentation
- google-cloud-speech on RubyGems
- Google Cloud Speech API documentation
$ gem install google-cloud-speech
require "google/cloud/speech"
speech = Google::Cloud::Speech.new
audio = speech.audio "path/to/audio.raw",
encoding: :raw, sample_rate: 16000
results = audio.recognize
result = results.first
result.transcript #=> "how old is the Brooklyn Bridge"
result.confidence #=> 0.9826789498329163
In order to use this library, you first need to go through the following steps:
- Select or create a Cloud Platform project.
- Enable billing for your project.
- Enable the Cloud Scheduler API.
- Setup Authentication.
$ gem install google-cloud-scheduler
- Read the Client Library Documentation for Cloud Scheduler API to see other available methods on the client.
- Read the Cloud Scheduler API Product documentation to learn more about the product and see How-to Guides.
- View this repository's main README to see the full list of Cloud APIs that we cover.
To enable logging for this library, set the logger for the underlying gRPC library.
The logger that you set may be a Ruby stdlib Logger
as shown below,
or a Google::Cloud::Logging::Logger
that will write logs to Stackdriver Logging. See grpc/logconfig.rb
and the gRPC spec_helper.rb for additional information.
Configuring a Ruby stdlib logger:
require "logger"
module MyLogger
LOGGER = Logger.new $stderr, level: Logger::WARN
def logger
LOGGER
end
end
# Define a gRPC module-level logger method before grpc/logconfig.rb loads.
module GRPC
extend MyLogger
end
- google-cloud-secret_manager README
- google-cloud-automl API documentation
- google-cloud-secret_manager on RubyGems
$ gem install google-cloud-secret_manager
- google-cloud-security_center README
- google-cloud-security_center API documentation
- google-cloud-security_center on RubyGems
- Google Cloud Security Center API documentation
$ gem install google-cloud-security_center
- google-cloud-storage README
- google-cloud-storage API documentation
- google-cloud-storage on RubyGems
- Google Cloud Storage documentation
$ gem install google-cloud-storage
require "google/cloud/storage"
storage = Google::Cloud::Storage.new(
project_id: "my-todo-project",
credentials: "/path/to/keyfile.json"
)
bucket = storage.bucket "task-attachments"
file = bucket.file "path/to/my-file.ext"
# Download the file to the local file system
file.download "/tasks/attachments/#{file.name}"
# Copy the file to a backup bucket
backup = storage.bucket "task-attachment-backups"
file.copy backup, file.name
- google-cloud-talent README
- google-cloud-talent API documentation
- google-cloud-talent on RubyGems
- Google Cloud Talent Solutions documentation
$ gem install google-cloud-talent
require "google/cloud/talent"
require "google/cloud/talent"
job_service_client = Google::Cloud::Talent::JobService.new(version: :v4beta1)
formatted_parent = job_service_client.project_path("[PROJECT]")
# TODO: Initialize `filter`:
filter = ''
# Iterate over all results.
job_service_client.list_jobs(formatted_parent, filter).each do |element|
# Process element.
end
# Or iterate over results one page at a time.
job_service_client.list_jobs(formatted_parent, filter).each_page do |page|
# Process each page at a time.
page.each do |element|
# Process element.
end
end
$ gem install google-cloud-tasks
require "google/cloud/tasks/v2beta2"
cloud_tasks_client = Google::Cloud::Tasks::V2beta2.new
formatted_parent = Google::Cloud::Tasks::V2beta2::CloudTasksClient.location_path("[PROJECT]", "[LOCATION]")
# Iterate over all results.
cloud_tasks_client.list_queues(formatted_parent).each do |element|
# Process element.
end
# Or iterate over results one page at a time.
cloud_tasks_client.list_queues(formatted_parent).each_page do |page|
# Process each page at a time.
page.each do |element|
# Process element.
end
end
$ gem install google-cloud-text_to_speech
require "google/cloud/text_to_speech"
text_to_speech_client = Google::Cloud::TextToSpeech.new
text = "test"
input = { text: text }
language_code = "en-US"
voice = { language_code: language_code }
audio_encoding = :MP3
audio_config = { audio_encoding: audio_encoding }
response = text_to_speech_client.synthesize_speech(input, voice, audio_config)
File.write("example.mp3", response.audio_content, mode: "wb")
- google-cloud-translate README
- google-cloud-translate API documentation
- google-cloud-translate on RubyGems
- Google Cloud Translation API documentation
$ gem install google-cloud-translate
require "google/cloud/translate"
translate = Google::Cloud::Translate.new
translation = translate.translate "Hello world!", to: "la"
puts translation #=> Salve mundi!
translation.from #=> "en"
translation.origin #=> "Hello world!"
translation.to #=> "la"
translation.text #=> "Salve mundi!"
- google-cloud-vision README
- google-cloud-vision API documentation
- google-cloud-vision on RubyGems
- Google Cloud Vision API documentation
$ gem install google-cloud-vision
require "google/cloud/vision"
image_annotator_client = Google::Cloud::Vision::ImageAnnotator.new
gcs_image_uri = "gs://gapic-toolkit/President_Barack_Obama.jpg"
source = { gcs_image_uri: gcs_image_uri }
image = { source: source }
type = :FACE_DETECTION
features_element = { type: type }
features = [features_element]
requests_element = { image: image, features: features }
requests = [requests_element]
response = image_annotator_client.batch_annotate_images(requests)
- google-cloud-monitoring README
- google-cloud-monitoring API documentation
- google-cloud-monitoring on RubyGems
- Google Cloud Monitoring API documentation
$ gem install google-cloud-monitoring
require "google/cloud/monitoring/v3"
MetricServiceClient = Google::Cloud::Monitoring::V3::MetricServiceClient
metric_service_client = MetricServiceClient.new
formatted_name = MetricServiceClient.project_path(project_id)
# Iterate over all results.
metric_service_client.list_monitored_resource_descriptors(formatted_name).each do |element|
# Process element.
end
# Or iterate over results one page at a time.
metric_service_client.list_monitored_resource_descriptors(formatted_name).each_page do |page|
# Process each page at a time.
page.each do |element|
# Process element.
end
end
- google-cloud-video_intelligence README
- google-cloud-video_intelligence API documentation
- google-cloud-video_intelligence on RubyGems
- Google Cloud Video Intelligence API documentation
$ gem install google-cloud-video_intelligence
require "google/cloud/video_intelligence/v1beta2"
video_intelligence_service_client = Google::Cloud::VideoIntelligence.new
input_uri = "gs://cloud-ml-sandbox/video/chicago.mp4"
features_element = :LABEL_DETECTION
features = [features_element]
# Register a callback during the method call.
operation = video_intelligence_service_client.annotate_video(input_uri: input_uri, features: features) do |op|
raise op.results.message if op.error?
op_results = op.results
# Process the results.
metadata = op.metadata
# Process the metadata.
end
# Or use the return value to register a callback.
operation.on_done do |op|
raise op.results.message if op.error?
op_results = op.results
# Process the results.
metadata = op.metadata
# Process the metadata.
end
# Manually reload the operation.
operation.reload!
# Or block until the operation completes, triggering callbacks on
# completion.
operation.wait_until_done!
$ gem install google-cloud-webrisk
These libraries are currently supported on Ruby 2.4+.
Google provides official support for Ruby versions that are actively supported by Ruby Core—that is, Ruby versions that are either in normal maintenance or in security maintenance, and not end of life. Currently, this means Ruby 2.4 and later. Older versions of Ruby may still work, but are unsupported and not recommended. See https://www.ruby-lang.org/en/downloads/branches/ for details about the Ruby support schedule.
The libraries in this repository follow Semantic Versioning.
Note that different libraries may be released at different support quality levels:
GA: Libraries defined at the GA (general availability) quality level, indicated by a version number greater than or equal to 1.0, are stable. The code surface will not change in backwards-incompatible ways unless absolutely necessary (e.g. because of critical security issues), or unless accompanying a semver-major version update (such as version 1.x to 2.x.) Issues and requests against GA libraries are addressed with the highest priority.
Beta: Libraries defined at a Beta quality level, indicated by a version number less than 1.0, are expected to be mostly stable and we're working towards their release candidate. However, these libraries may get backwards-incompatible updates from time to time. We will still address issues and requests with a high priority.
Contributions to this library are always welcome and highly encouraged.
See CONTRIBUTING for more information on how to get started.
Please note that this project is released with a Contributor Code of Conduct. By participating in this project you agree to abide by its terms. See Code of Conduct for more information.
This library is licensed under Apache 2.0. Full license text is available in LICENSE.
Please report bugs at the project on Github. Don't hesitate to ask questions about the client or APIs on StackOverflow.