Greg Furman

Read bento config from environment variables

13

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. ---...

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...

HuggingBento: A Bento-flavoured distro running Hugging Face Transformers

1

### 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...

Which repositories in benthosdev should be forked?

3

There are a couple of repos still in [benthosdev](https://github.com/benthosdev) i.e [helm-charts](https://github.com/benthosdev/benthos-helm-chart) & [example plugin repo](https://github.com/benthosdev/benthos-plugin-example). Are these also going to be forked and maintained or is it safe to assume...

I noticed there are no tests for [internal/impl/pure/bloblang_numbers.go](https://github.com/warpstreamlabs/bento/blob/main/internal/impl/pure/bloblang_numbers.go). There is probably some low-hanging fruit functionality that can be added here so adding some test coverage would be useful.

## Motivation This PR fixes the case where a Lambda is deleted prior to an Event Source Mapping raises an resource not found exception. - Note: This PR relies on...

[ESM] Sync coverage table with improved batching support

1

## Changes - Change SQS Standard queue `BatchSize` coverage from 🟡 to 🟢 - Change SQS/Kinesis/DynamoDB Streams `MaximumBatchingWindowInSeconds` coverage from 🟠 to 🟢

## Changes - Adds `ApproximateArrivalTimestamp` from `Kinesis::GetRecords` as metadata `kinesis_approximate_arrival_timestamp` in message

## Context When running in Bento in Streams mode, a comprehensive REST API is offered for CRUD operations. This allows a user to interact with their streams mode instance via...

In the serverless docs we have some refs to outdated `makenew` plugins that @razor-x originally contributed. We should therefore create some bento alternatives to the following: - [makenew/serverless-benthos](https://github.com/makenew/serverless-benthos) - [makenew/benthos-plugin](https://github.com/makenew/benthos-plugin)