Microsoft Azure Storage Client Library for Ruby

• Master:
• Dev:

This project provides a Ruby package that makes it easy to access and manage Microsoft Azure Storage Services.

Library Features

• Blobs
• Tables
• Queues

Supported Ruby Versions

• Ruby 2.0
• Ruby 2.1
• Ruby 2.2

Note:

• x64 Ruby for Windows is known to have some compatibility issues.
• azure-storage depends on gem nokogiri, which doesn't support Ruby 2.2+ on Windows.

Getting Started

Install the rubygem package

You can install the azure rubygem package directly.

gem install azure-storage --pre

Setup Connection

You can use this SDK against the Microsoft Azure Storage Services in the cloud, or against the local Storage Emulator if you are on Windows.

There are two ways you can set up the connections:

1. via code
2. via environment variables

Via Code

• Against Microsoft Azure Services in the cloud

  require "azure/storage"

  # Setup a specific instance of an Azure::Storage::Client
  client = Azure::Storage::Client.create(:storage_account_name => "your account name", :storage_access_key => "your access key")

  # Or create a client and store as a singleton
  Azure::Storage.setup(:storage_account_name => "your account name", :storage_access_key => "your access key")
  # Then you can either call Azure::Storage.client.some_method or Azure::Storage.some_method to invoke a method on the Storage Client

  # Configure a ca_cert.pem file if you are having issues with ssl peer verification
  client.ca_file = "./ca_file.pem"

• Against local Emulator (Windows Only)

  require "azure/storage"
  client = Azure::Storage::Client.create_develpoment

  # Or create by options and provide your own proxy_uri
  client = Azure::Storage::Client.create(:use_development_storage => true, :development_storage_proxy_uri => "your proxy uri")

Via Environment Variables

• Against Microsoft Azure Storage Services in the cloud

  export AZURE_STORAGE_ACCOUNT = <your azure storage account name>
  export AZURE_STORAGE_ACCESS_KEY = <your azure storage access key>

• Against local Emulator (Windows Only)

  export EMULATED = true

• SSL Certificate File if having issues with ssl peer verification

  SSL_CERT_FILE=<path to *.pem>

Usage

Blobs

# Require the azure storage rubygem
require "azure/storage"

# Setup a specific instance of an Azure::Storage::Client
client = Azure::Storage::Client.create(:storage_account_name => "your account name", :storage_access_key => "your access key")

# Get an azure storage blob service object from a specific instance of an Azure::Storage::Client
blobs = client.blob_client

# Or setup the client as a singleton
Azure::Storage.setup(:storage_account_name => "your account name", :storage_access_key => "your access key")

# Create an azure storage blob service object after you set up the credentials
blobs = Azure::Storage::Blob::BlobService.new

# Add retry filter to the service object
blobs.with_filter(Azure::Storage::Core::Filter::ExponentialRetryPolicyFilter.new)

# Create a container
container = blobs.create_container("test-container")

# Upload a Blob
content = File.open('test.jpg', 'rb') { |file| file.read }
blobs.create_block_blob(container.name, "image-blob", content)

# List containers
blobs.list_containers()

# List Blobs
blobs.list_blobs(container.name)

# Download a Blob
blob, content = blobs.get_blob(container.name, "image-blob")
File.open("download.png", "wb") {|f| f.write(content)}

# Delete a Blob
blobs.delete_blob(container.name, "image-blob")

Tables

# Require the azure storage rubygem
require "azure/storage"

# Setup a specific instance of an Azure::Storage::Client
client = Azure::Storage::Client.create(:storage_account_name => "your account name", :storage_access_key => "your access key")

# Get an azure storage table service object from a specific instance of an Azure::Storage::Client
tables = client.table_client

# Or setup the client as a singleton
Azure::Storage.setup(:storage_account_name => "your account name", :storage_access_key => "your access key")

# Create an azure storage table service object after you set up the credentials
tables = Azure::Storage::Table::TableService.new

# Add retry filter to the service object
tables.with_filter(Azure::Storage::Core::Filter::ExponentialRetryPolicyFilter.new)

# Create a table
tables.create_table("testtable")

# Insert an entity
entity = { content: "test entity", PartitionKey: "test-partition-key", RowKey: "1" }
tables.insert_entity("testtable", entity)

# Get an entity
result = tables.get_entity("testtable", "test-partition-key", "1")

# Update an entity
result.properties["content"] = "test entity with updated content"
tables.update_entity(result.table, result.properties)

# Query entities
query = { :filter => "content eq 'test entity'" }
result, token = tables.query_entities("testtable", query)

# Delete an entity
tables.delete_entity("testtable", "test-partition-key", "1")

# delete a table
tables.delete_table("testtable")

Queues

# Require the azure storage rubygem
require "azure/storage"

# Setup a specific instance of an Azure::Storage::Client
client = Azure::Storage::Client.create(:storage_account_name => "your account name", :storage_access_key => "your access key")

# Get an azure storage queue service object from a specific instance of an Azure::Storage::Client
queues = client.queue_client

# Or setup the client as a singleton
Azure::Storage.setup(:storage_account_name => "your account name", :storage_access_key => "your access key")

# Create an azure storage queue service object after you set up the credentials
queues = Azure::Storage::Queue::QueueService.new

# Add retry filter to the service object
queues.with_filter(Azure::Storage::Core::Filter::ExponentialRetryPolicyFilter.new)

# Create a queue
queues.create_queue("test-queue")

# Create a message
queues.create_message("test-queue", "test message")

# Get one or more messages with setting the visibility timeout
result = queues.list_messages("test-queue", 30, { number_of_messages: 10 })

# Get one or more messages without setting the visibility timeout
result = queues.peek_messages("test-queue", { number_of_messages: 10 })

# Update a message
message = queues.list_messages("test-queue", 30)
pop_receipt, time_next_visible = queues.update_message("test-queue", message[0].id, message[0].pop_receipt, "updated test message", 30)

# Delete a message
message = queues.list_messages("test-queue", 30)
queues.delete_message("test-queue", message[0].id, message[0].pop_receipt)

# Delete a queue
queues.delete_queue("test-queue")

Getting Started for Contributors

If you would like to become an active contributor to this project please follow the instructions provided in Azure Projects Contribution Guidelines. You can find more details for contributing in the CONTRIBUTING.md.

Provide Feedback

If you encounter any bugs with the library please file an issue in the Issues section of the project.

Azure Storage SDKs and Tooling

• Azure Storage Client Library for .Net
• Azure Storage Client Library for Java
• Azure Storage Client Library for Node.js
• Azure Storage Client Library for Python
• Azure Storage Client Library for Ruby
• Azure Storage Client Library for C++
• Azure Storage Client Library for iOS
• Azure Storage Client Library for Android
• Azure Storage Data Movement Library

Code of Conduct

This project has adopted the Microsoft Open Source Code of Conduct. For more information see the Code of Conduct FAQ or contact [email protected] with any additional questions or comments.