bento.yml

http:
  enabled: true
  address: 0.0.0.0:4195
  root_path: /bento
  debug_endpoints: false
  cors:
    enabled: false
    allowed_origins: []
  basic_auth:
    enabled: false
    realm: restricted
    username: ''
    password_hash: ''
    algorithm: sha256
    salt: ''
input:
  aws_kinesis:
    streams: [${GOOD_STREAM}]
    dynamodb:
      table: 'test-bento'
      create: true
      billing_mode: PAY_PER_REQUEST
      read_capacity_units: 0
      write_capacity_units: 0
    checkpoint_limit: 1024
    auto_replay_nacks: true
    commit_period: 5s
    rebalance_period: 30s
    lease_period: 30s
    start_from_oldest: true
    region: ${AWS_REGION}
    endpoint: ''
    credentials:
      profile: 'agondata'
    batching:
      count: 0
      byte_size: 0
      period: ''
      check: ''
      processors: [] # No default (optional)
buffer:
  none: {}

pipeline:
  processors:
    - mapping: |
        root = this.payload
output:
  type: broker
  broker:
    pattern: fan_out
    outputs: 
      - type: stdout
        stdout:
          codec: lines

      - type: snowflake_put
        snowflake_put:
          account: bv1337
          cloud: aws
          user: DEV
          private_key_file: 'rsa_key.p8'
          role: ROLS
          database: DEV
          warehouse: MYWH
          schema: BUZ
          stage: PIXEL
          
          batching:
            count: 2
            period: 3s
input_resources: []
processor_resources: []
output_resources: []
cache_resources: []
rate_limit_resources: []
logger:
  level: INFO
  format: logfmt
  add_timestamp: false
  level_name: level
  timestamp_name: time
  message_name: msg
  static_fields:
    '@service': bento
  file:
    path: ''
    rotate: false
    rotate_max_age_days: 0
metrics:
  json_api: {}
  mapping: ''
tracer:
  none: {}
shutdown_delay: 0s
shutdown_timeout: 2s
tests: []