diff --git a/README.md b/README.md
index 8f79f48..c65d1e0 100644
--- a/README.md
+++ b/README.md
@@ -32,11 +32,11 @@ PackageReference
 Use one the following ways to initialize `CosmosDbStorage`
 
 ```csharp
-GlobalConfiguration.Configuration.UseAzureCosmosDbStorage("<url>", "<authSecret>", "<databaseName>", "<collectionName>");
+GlobalConfiguration.Configuration.UseAzureCosmosDbStorage("<url>", "<authSecret>", "<databaseName>", "<containerName>");
 
 ------------------------------------------------ 
 
-Hangfire.Azure.CosmosDbStorage storage = Hangfire.Azure.CosmosDbStorage.Create("<url>", "<authSecret>", "<databaseName>", "<collectionName>");
+Hangfire.Azure.CosmosDbStorage storage = Hangfire.Azure.CosmosDbStorage.Create("<url>", "<authSecret>", "<databaseName>", "<containerName>");
 GlobalConfiguration.Configuration.UseStorage(storage);
 ```
 
@@ -46,14 +46,15 @@ Hangfire.Azure.CosmosDbStorageOptions options = new Hangfire.Azure.CosmosDbStora
 {
     ExpirationCheckInterval = TimeSpan.FromMinutes(2),
     CountersAggregateInterval = TimeSpan.FromMinutes(2),
-    QueuePollInterval = TimeSpan.FromSeconds(15)
+    QueuePollInterval = TimeSpan.FromSeconds(15),
+    CreateIfNotExists = true
 };
 
-GlobalConfiguration.Configuration.UseAzureCosmosDbStorage("<url>", "<authSecret>", "<databaseName>", "<collectionName>", cosmoClientOptions, options);
+GlobalConfiguration.Configuration.UseAzureCosmosDbStorage("<url>", "<authSecret>", "<databaseName>", "<containerName>", cosmoClientOptions, options);
 
 ------------------------------------------------ 
 
-Hangfire.Azure.CosmosDbStorage storage = Hangfire.Azure.CosmosDbStorage.Create("<url>", "<authSecret>", "<databaseName>", "<collectionName>", cosmoClientOptions, options);
+Hangfire.Azure.CosmosDbStorage storage = Hangfire.Azure.CosmosDbStorage.Create("<url>", "<authSecret>", "<databaseName>", "<containerName>", cosmoClientOptions, options);
 GlobalConfiguration.Configuration.UseStorage(storage);
 ```
 
diff --git a/src/CosmosDbStorage.cs b/src/CosmosDbStorage.cs
index cdc63e0..c15043b 100644
--- a/src/CosmosDbStorage.cs
+++ b/src/CosmosDbStorage.cs
@@ -3,6 +3,7 @@
 using System.Collections.ObjectModel;
 using System.IO;
 using System.Linq;
+using System.Net;
 using System.Reflection;
 using System.Text;
 using System.Threading;
@@ -150,7 +151,9 @@ public override void WriteOptionsToLog(ILog log)
         info.AppendLine($"	Region: [{Client.ClientOptions.ApplicationRegion}]");
         info.AppendLine($"	Max Retry Attempts On Rate Limited Requests: [{Client.ClientOptions.MaxRetryAttemptsOnRateLimitedRequests}]");
         info.AppendLine($"	Max Retry Wait Time On Rate Limited Requests: [{Client.ClientOptions.MaxRetryWaitTimeOnRateLimitedRequests!.Value}]");
+        info.AppendLine($"	Create Storage If Not Exists: [{StorageOptions.CreateIfNotExists}]");
         info.AppendLine($"	Counter Aggregator Max Items: [{StorageOptions.CountersAggregateMaxItemCount}]");
+        info.AppendLine($"	Transactional Lock Timeout: [{StorageOptions.TransactionalLockTimeout}]");
         info.AppendLine($"	Counter Aggregate Interval: [{StorageOptions.CountersAggregateInterval}]");
         info.AppendLine($"	Queue Poll Interval: [{StorageOptions.QueuePollInterval}]");
         info.AppendLine($"	Expiration Check Interval: [{StorageOptions.ExpirationCheckInterval}]");
@@ -239,6 +242,20 @@ public static async Task<CosmosDbStorage> CreateAsync(CosmosClient cosmosClient,
 
     private async Task InitializeAsync(CancellationToken cancellationToken = default)
     {
+        if (!StorageOptions.CreateIfNotExists)
+        {
+            // check if container exists within database
+            try
+            {
+                Container = await Client.GetContainer(databaseName, containerName).ReadContainerAsync(cancellationToken: cancellationToken);
+                return;
+            }
+            catch (CosmosException ex) when (ex.StatusCode == HttpStatusCode.NotFound)
+            {
+                throw new InvalidOperationException($"Cannot find an existing container named {containerName} within database {databaseName}");
+            }
+        }
+        
         // create database
         logger.Info($"Creating database : [{databaseName}]");
         DatabaseResponse databaseResponse = await Client.CreateDatabaseIfNotExistsAsync(databaseName, cancellationToken: cancellationToken);
diff --git a/src/CosmosDbStorageOptions.cs b/src/CosmosDbStorageOptions.cs
index bf98a75..a40309d 100644
--- a/src/CosmosDbStorageOptions.cs
+++ b/src/CosmosDbStorageOptions.cs
@@ -9,6 +9,12 @@ namespace Hangfire.Azure;
 /// </summary>
 public class CosmosDbStorageOptions
 {
+	/// <summary>
+	///		Gets or sets a value indicating whether initialization will check for the Container existence and create it if it doesn't exist.
+	/// </summary>
+	/// <value>Default value is true</value>
+	public bool CreateIfNotExists { get; set; } = true;
+
 	/// <summary>
 	///     Get or set the interval timespan to process expired entries. Default value 30 minutes.
 	///     Expired items under "locks", "jobs", "lists", "sets", "hashs", "counters", "state" will be checked