Write key-value pairs
To create a new key-value pair, or to update the value for a particular key, call the put() method of the KV binding on any KV namespace you have bound to your Worker code:
env.NAMESPACE.put(key, value);An example of writing a key-value pair from within a Worker:
export default { async fetch(request, env, ctx) { try { await env.NAMESPACE.put("first-key", "This is the value for the key");
return new Response("Successful write", { status: 201, }); } catch (e) { return new Response(e.message, { status: 500 }); } },};The following method is provided to write to KV:
To create a new key-value pair, or to update the value for a particular key, call the put() method on any KV namespace you have bound to your Worker code:
env.NAMESPACE.put(key, value, options?);-
key:string- The key to associate with the value. A key cannot be empty or be exactly equal to
.or... All other keys are valid. Keys have a maximum length of 512 bytes.
- The key to associate with the value. A key cannot be empty or be exactly equal to
-
value:string|ReadableStream|ArrayBuffer- The value to store. The type is inferred. The maximum size of a value is 25 MiB.
-
options:{ expiration?: number, expirationTtl?: number, metadata?: object }- Optional. An object containing the
expiration(optional),expirationTtl(optional), andmetadata(optional) attributes.expirationis the number that represents when to expire the key-value pair in seconds since epoch.expirationTtlis the number that represents when to expire the key-value pair in seconds from now. The minimum value is 60.metadatais an object that must serialize to JSON. The maximum size of the serialized JSON representation of the metadata object is 1024 bytes.
- Optional. An object containing the
response:Promise<void>- A
Promisethat resolves if the update is successful.
- A
The put() method returns a Promise that you should await on to verify a successful update.
Due to the eventually consistent nature of KV, concurrent writes to the same key can end up overwriting one another. It is a common pattern to write data from a single process with Wrangler or the API. This avoids competing concurrent writes because of the single stream. All data is still readily available within all Workers bound to the namespace.
If concurrent writes are made to the same key, the last write will take precedence.
Writes are immediately visible to other requests in the same global network location, but can take up to 60 seconds (or the value of the cacheTtl parameter of the get() or getWithMetadata() methods) to be visible in other parts of the world.
Refer to How KV works for more information on this topic.
Write more than one key-value pair at a time with Wrangler or via the REST API.
The bulk API can accept up to 10,000 KV pairs at once.
A key and a value are required for each KV pair. The entire request size must be less than 100 megabytes. Bulk writes are not supported using the KV binding.
KV offers the ability to create keys that automatically expire. You may configure expiration to occur either at a particular point in time, or after a certain amount of time has passed since the key was last modified.
Once the expiration time of an expiring key is reached, it will be deleted from the system. After its deletion, attempts to read the key will behave as if the key does not exist. The deleted key will not count against the KV namespace’s storage usage for billing purposes.
There are two ways to specify when a key should expire:
-
Set a key's expiration using an absolute time specified in a number of seconds since the UNIX epoch ↗. For example, if you wanted a key to expire at 12:00AM UTC on April 1, 2019, you would set the key’s expiration to
1554076800. -
Set a key's expiration time to live (TTL) using a relative number of seconds from the current time. For example, if you wanted a key to expire 10 minutes after creating it, you would set its expiration TTL to
600.
Expiration targets that are less than 60 seconds into the future are not supported. This is true for both expiration methods.
To create expiring keys, set expiration in the put() options to a number representing the seconds since epoch, or set expirationTtl in the put() options to a number representing the seconds from now:
await env.NAMESPACE.put(key, value, { expiration: secondsSinceEpoch,});
await env.NAMESPACE.put(key, value, { expirationTtl: secondsFromNow,});These assume that secondsSinceEpoch and secondsFromNow are variables defined elsewhere in your Worker code.
To associate metadata with a key-value pair, set metadata in the put() options to an object (serializable to JSON):
await env.NAMESPACE.put(key, value, { metadata: { someMetadataKey: "someMetadataValue" },});Workers KV has a maximum of 1 write to the same key per second. Writes made to the same key within 1 second will cause rate limiting (429) errors to be thrown.
You should not write more than once per second to the same key. Consider consolidating your writes to a key within a Worker invocation to a single write, or wait at least 1 second between writes.
The following example serves as a demonstration of how multiple writes to the same key may return errors by forcing concurrent writes within a single Worker invocation. This is not a pattern that should be used in production.
export default { async fetch(request, env, ctx): Promise<Response> { // Rest of code omitted const key = "common-key"; const parallelWritesCount = 20;
// Helper function to attempt a write to KV and handle errors const attemptWrite = async (i: number) => { try { await env. YOUR_KV_NAMESPACE.put(key, `Write attempt #${i}`); return { attempt: i, success: true }; } catch (error) { // An error may be thrown if a write to the same key is made within 1 second with a message. For example: // error: { // "message": "KV PUT failed: 429 Too Many Requests" // }
return { attempt: i, success: false, error: { message: (error as Error).message }, }; } };
// Send all requests in parallel and collect results const results = await Promise.all( Array.from({ length: parallelWritesCount }, (_, i) => attemptWrite(i + 1), ), ); // Results will look like: // [ // { // "attempt": 1, // "success": true // }, // { // "attempt": 2, // "success": false, // "error": { // "message": "KV PUT failed: 429 Too Many Requests" // } // }, // ... // ]
return new Response(JSON.stringify(results), { headers: { "Content-Type": "application/json" }, }); },};To handle these errors, we recommend implementing a retry logic, with exponential backoff. Here is a simple approach to add retries to the above code.
export default { async fetch(request, env, ctx): Promise<Response> { // Rest of code omitted const key = "common-key"; const parallelWritesCount = 20;
// Helper function to attempt a write to KV with retries const attemptWrite = async (i: number) => { return await retryWithBackoff(async () => { await env.YOUR_KV_NAMESPACE.put(key, `Write attempt #${i}`); return { attempt: i, success: true }; }); };
// Send all requests in parallel and collect results const results = await Promise.all( Array.from({ length: parallelWritesCount }, (_, i) => attemptWrite(i + 1), ), );
return new Response(JSON.stringify(results), { headers: { "Content-Type": "application/json" }, }); },};
async function retryWithBackoff( fn: Function, maxAttempts = 5, initialDelay = 1000,) { let attempts = 0; let delay = initialDelay;
while (attempts < maxAttempts) { try { // Attempt the function return await fn(); } catch (error) { // Check if the error is a rate limit error if ( (error as Error).message.includes( "KV PUT failed: 429 Too Many Requests", ) ) { attempts++; if (attempts >= maxAttempts) { throw new Error("Max retry attempts reached"); }
// Wait for the backoff period console.warn(`Attempt ${attempts} failed. Retrying in ${delay} ms...`); await new Promise((resolve) => setTimeout(resolve, delay));
// Exponential backoff delay *= 2; } else { // If it's a different error, rethrow it throw error; } } }}You can also write key-value pairs from the command line with Wrangler and write data via the REST API.