Só metadado

from niadra import Niadra

niadra = Niadra()
niadra.turns.store(s3_bucket="s3://acme-agent-turns/prod")  # boto3, with your credentials from the environment
# or any callable put(key, data) -> pointer
niadra.turns.store(put=lambda key, data: my_store.write(key, data))

import { Niadra } from "@niadra/sdk";
import { PutObjectCommand, S3Client } from "@aws-sdk/client-s3";

const niadra = new Niadra();
const s3 = new S3Client({});
niadra.turns.store(async (key, data) => {
  await s3.send(new PutObjectCommand({ Bucket: "acme-agent-turns", Key: `prod/${key}`, Body: data, ContentType: "application/json" }));
  return `s3://acme-agent-turns/prod/${key}`;
});

import boto3

s3 = boto3.client("s3")


def fetch(pointer: str) -> bytes:
    bucket, key = pointer.removeprefix("s3://").split("/", 1)
    return s3.get_object(Bucket=bucket, Key=key)["Body"].read()


niadra.content.register(fetch)  # the Replayer reads pointers through it

import { GetObjectCommand } from "@aws-sdk/client-s3";

niadra.content.register(async (pointer) => {
  const [bucket, key] = pointer.replace("s3://", "").split(/\/(.+)/);
  const object = await s3.send(new GetObjectCommand({ Bucket: bucket, Key: key }));
  return await object.Body!.transformToString();
});