Testing Observability Pipeline

[francisan]

Hi,

How I can test below pipeline using some sample payload. Want to test/ensure connector routes the request to corresponding pipeline based on the field 'name'.

receivers:
webhookevent:

  endpoint: 0.0.0.0:1111
  path: /get/info

processors:
transform/tr:

   error_mode: ignore
   log_statements:
    - context: log
      statements:
       - set(body, ParseJSON(body)) where body != nil
       - set(resource.attributes["name"], body["name"])

connectors:
routing :
table:
- statement: route() where attributes["name"] == "abc"
pipelines:
- logs/abc
- statement: route() where attributes["name"] == "xyz"
pipelines:
- logs/xyz

exporters:
logging:
loglevel: debug

service:
pipelines:

logs/receivers:
receivers: [webhookevent]
processors: [transform/tr]
exporters: [routing,logging]

logs/abc:
receivers: [routing]
processors: []
exporters: [logging]

logs/xyz:
receivers: [routing]
processors: []
exporters: [logging]

Want to build something as shown below. Any existing test frameworks available?
type: Test
spec:
id: 19L__G7IR
name: Call API
trigger:
type: http
httpRequest:
url: http://host.docker.internal:1111/get/info
method: POST
headers:
- key: Content-Type
value: application/json
specs:

assertions:
- attr:http.status_code  =  200

[danielbdias]

hi @francisan , I noticed this issue is related to your report on kubeshop/tracetest#3997.

I believe that is not related to the OTel Demo itself (feel free to correct me if I'm wrong @puckpuck and @julianocosta89)

Are you trying to validate a behavior on your OTel Collector right?

[francisan]

@danielbdias Yes, you are right. Will discuss this in other thread (kubeshop/tracetest#3997).