A time series database for big data
Try to use it with SDKs:
import time
import asyncio
from reduct import Client, Bucket
async def main():
client = Client('https://play.reduct-storage.dev')
bucket: Bucket = await client.create_bucket("my-bucket", exist_ok=True)
ts = time.time_ns() / 1000
await bucket.write("entry-1", b"Hey!!", ts)
async with bucket.read("entry-1", ts) as record:
data = await record.read_all()
print(data)
loop = asyncio.get_event_loop()
loop.run_until_complete(main())const {Client} = require("reduct-js")
const client = new Client("https://play.reduct-storage.dev");
const main = async () => {
const bucket = await client.getOrCreateBucket("bucket");
const timestamp = Date.now() * 1000;
let record = await bucket.beginWrite("entry-1", timestamp);
await record.write("Hello, World!");
record = await bucket.beginRead("entry-1", timestamp);
console.log((await record.read()).toString());
};
main()
.then(() => console.log("done"))
.catch((err) => console.error("oops: ", err));#include <reduct/client.h>
#include <iostream>
using reduct::IBucket;
using reduct::IClient;
int main() {
auto client = IClient::Build("https://play.reduct-storage.dev");
auto [bucket, create_err] = client->GetOrCreateBucket("bucket");
IBucket::Time ts = IBucket::Time::clock::now();
[[maybe_unused]] auto err = bucket->Write("entry-1", ts, [](auto rec) {
rec->WriteAll("Hello, World!");
});
err = bucket->Read("entry-1", ts, [](auto rec) {
std::cout << "Read record: "
<< rec.ReadAll().result << std::endl;
return true;
});
}export HEADER="Authorization: Bearer reduct" # use `reduct` token
export API_PATH="https://play.reduct-storage.dev/api/v1"
# Create a bucket
curl -d "{\"quota_type\":\"FIFO\", \"quota_size\":10000}" \
-X POST --header "${HEADER}" \
-a "${API_PATH}"/b/my_data
# Write some data
export TIME=`date +%s000000`
curl -d "some_data" \
-X POST --header "${HEADER}" \
-a ${API_PATH}/b/my_data/entry_1?ts=${TIME}
# Read the data by using its timestamp
curl --header "${HEADER}" \
-a ${API_PATH}/b/my_data/entry_1?ts=${TIME}
