bento
bento copied to clipboard
Fancy stream processing made operationally mundane. This repository is a fork of the original project before the license was changed.
**Description:** As a user, I would like to be able to connect to an AWS RDS instance (PostgreSQL) for reading and writing data using IAM roles instead of providing a...
At the moment http_server websocket implementation just writes to webscocket, and do not have a way to detect client disconnect proactively. More over, if client disconnects, and it fails write...
https://warpstreamlabs.github.io/bento/docs/configuration/templating/ Code: ```go //go:embed bento.yaml var bento string //go:embed trackstar/input_template.yaml var inputTemplate string //go:embed trackstar/output_template.yaml var outputTemplate string //go:embed trackstar/dead_letter_template.yaml var deadLetterTemplate string //go:embed trackstar/processor_resources.yaml var processorResources string func main()...
Currently, only the `bento-lambda` distribution allows for reading of bento config from the environment via the `BENTO_CONFIG` and `BENTO_CONFIG_PATH` variables. https://github.com/warpstreamlabs/bento/blob/1d22b5d9e7f0214e3a074e191eec21ee6b7d9a35/internal/serverless/lambda/lambda.go#L31-L41 We should extend `bento` to include this functionality. ---...
Bumps the production-dependencies group with 60 updates in the / directory: | Package | From | To | | --- | --- | --- | | [cloud.google.com/go/bigquery](https://github.com/googleapis/google-cloud-go) | `1.59.1` |...
This [Lambda Event Source Mapping (ESM) issue](https://github.com/warpstreamlabs/bento/issues/59) raised a few months ago highlighted that we can much better support the Bento serverless offering. Namely, there are some common patterns and...
Add Neo4j components to Bento
### What is this? Create distribution of Bento for usage with NLP pipelines. This uses the [knights-analytics/hugot](https://github.com/knights-analytics/hugot) library to allow for running a Hugging Face pipeline with an ONNX model...