Example Vector config to pipe HTTP JSON to AMQP, with a routing key

vector_http_amqp.yaml

# Example: curl http://localhost:8000 --data '{"nested": {"flowID": "world"}, "data": "hello"}'

sources:
  in:
    type: http_server
    address: 0.0.0.0:8000
    codec: json

transforms:
  remap:
    type: remap
    inputs:
      - in
    source: |
      . = parse_json!(.message)
      ._vector.routingKey = .nested.flowID

sinks:
  sink_amqp:
    type: amqp
    inputs:
      - remap
    connection_string: amqp://user:[email protected]:5672/%2f?timeout=10
    routing_key: "{{ ._vector.routingKey }}"
    exchange: example
    encoding:
      except_fields: [_vector]
      codec: json