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

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

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_from_column("cf2", "field02") table.mutate_row(entry)

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

require "google/cloud/debugger" debugger = Google::Cloud::Debugger.new debugger.start

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

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)

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

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)

require "google/cloud/error_reporting" # Report an exception begin fail "Boom!" rescue => exception Google::Cloud::ErrorReporting.report exception end

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

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

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

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!

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"

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

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

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

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

 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

require "google/cloud/text_to_speech/v1" text_to_speech_client = Google::Cloud::TextToSpeech::V1.new input = {text: "Hello, world!"} voice = {language_code: "en-US"} audio_config = {audio_encoding: Google::Cloud::Texttospeech::V1::AudioEncoding::MP3} response = text_to_speech_client.synthesize_speech input, voice, audio_config File.open "hello.mp3", "w" do |file| file.write response.audio_content end

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!"

require "google/cloud/vision" vision = Google::Cloud::Vision.new image = vision.image "path/to/landmark.jpg" landmark = image.landmark landmark.description #=> "Mount Rushmore"

 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

 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!