testTelemetryPipeline method

Future<TestTelemetryPipelineOutput> testTelemetryPipeline({
  1. required TelemetryPipelineConfiguration configuration,
  2. required List<Record> records,
})

Tests a pipeline configuration with sample records to validate data processing before deployment. This operation helps ensure your pipeline configuration works as expected.

May throw AccessDeniedException. May throw InternalServerException. May throw TooManyRequestsException. May throw ValidationException.

Parameter configuration : The pipeline configuration to test with the provided sample records.

Parameter records : The sample records to process through the pipeline configuration for testing purposes.

Implementation

Future<TestTelemetryPipelineOutput> testTelemetryPipeline({
  required TelemetryPipelineConfiguration configuration,
  required List<Record> records,
}) async {
  final $payload = <String, dynamic>{
    'Configuration': configuration,
    'Records': records,
  };
  final response = await _protocol.send(
    payload: $payload,
    method: 'POST',
    requestUri: '/TestTelemetryPipeline',
    exceptionFnMap: _exceptionFns,
  );
  return TestTelemetryPipelineOutput.fromJson(response);
}