startFHIRImportJob method

Future<StartFHIRImportJobResponse> startFHIRImportJob({
  1. required String dataAccessRoleArn,
  2. required String datastoreId,
  3. required InputDataConfig inputDataConfig,
  4. required OutputDataConfig jobOutputDataConfig,
  5. String? clientToken,
  6. bool? driftDetectionEnabled,
  7. String? inputFormat,
  8. String? jobName,
  9. String? profileId,
  10. bool? provenanceEnabled,
  11. ValidationLevel? validationLevel,
})

Start importing bulk FHIR data into an ACTIVE data store. The import job imports FHIR data found in the InputDataConfig object and stores processing results in the JobOutputDataConfig object.

May throw AccessDeniedException. May throw FailedDependencyException. May throw InternalServerException. May throw ResourceNotFoundException. May throw ThrottlingException. May throw ValidationException.

Parameter dataAccessRoleArn : The Amazon Resource Name (ARN) that grants access permission to AWS HealthLake.

Parameter datastoreId : The data store identifier.

Parameter inputDataConfig : The input properties for the import job request.

Parameter clientToken : The optional user-provided token used for ensuring API idempotency.

Parameter jobName : The import job name.

Parameter provenanceEnabled : Specifies whether to enable provenance for the import job.

Parameter validationLevel : The validation level of the import job.

Implementation

Future<StartFHIRImportJobResponse> startFHIRImportJob({
  required String dataAccessRoleArn,
  required String datastoreId,
  required InputDataConfig inputDataConfig,
  required OutputDataConfig jobOutputDataConfig,
  String? clientToken,
  bool? driftDetectionEnabled,
  String? inputFormat,
  String? jobName,
  String? profileId,
  bool? provenanceEnabled,
  ValidationLevel? validationLevel,
}) async {
  final headers = <String, String>{
    'Content-Type': 'application/x-amz-json-1.0',
    'X-Amz-Target': 'HealthLake.StartFHIRImportJob'
  };
  final jsonResponse = await _protocol.send(
    method: 'POST',
    requestUri: '/',
    exceptionFnMap: _exceptionFns,
    // TODO queryParams
    headers: headers,
    payload: {
      'DataAccessRoleArn': dataAccessRoleArn,
      'DatastoreId': datastoreId,
      'InputDataConfig': inputDataConfig,
      'JobOutputDataConfig': jobOutputDataConfig,
      'ClientToken': clientToken ?? _s.generateIdempotencyToken(),
      if (driftDetectionEnabled != null)
        'DriftDetectionEnabled': driftDetectionEnabled,
      if (inputFormat != null) 'InputFormat': inputFormat,
      if (jobName != null) 'JobName': jobName,
      if (profileId != null) 'ProfileId': profileId,
      if (provenanceEnabled != null) 'ProvenanceEnabled': provenanceEnabled,
      if (validationLevel != null) 'ValidationLevel': validationLevel.value,
    },
  );

  return StartFHIRImportJobResponse.fromJson(jsonResponse.body);
}