Module Values.GetSparqlStreamOutputSource

Gets a stream for an RDF graph. With the Neptune Streams feature, you can generate a complete sequence of change-log entries that record every change made to your graph data as it happens. GetSparqlStream lets you collect these change-log entries for an RDF graph. The Neptune streams feature needs to be enabled on your Neptune DBcluster. To enable streams, set the neptune_streams DB cluster parameter to 1. See Capturing graph changes in real time using Neptune streams. When invoking this operation in a Neptune cluster that has IAM authentication enabled, the IAM user or role making the request must have a policy attached that allows the neptune-db:GetStreamRecords IAM action in that cluster. Note that the neptune-db:QueryLanguage:Sparql IAM condition key can be used in the policy document to restrict the use of SPARQL queries (see Condition keys available in Neptune IAM data-access policy statements).

Sourcetype nonrec t = {
  1. lastEventId : StringValuedMap.t option;
    (*

    Sequence identifier of the last change in the stream response. An event ID is composed of two fields: a commitNum, which identifies a transaction that changed the graph, and an opNum, which identifies a specific operation within that transaction:

    *)
  2. lastTrxTimestampInMillis : Long.t option;
    (*

    The time at which the commit for the transaction was requested, in milliseconds from the Unix epoch.

    *)
  3. format : String_.t option;
    (*

    Serialization format for the change records being returned. Currently, the only supported value is NQUADS.

    *)
  4. records : SparqlRecordsList.t option;
    (*

    An array of serialized change-log stream records included in the response.

    *)
  5. totalRecords : Integer.t option;
    (*

    The total number of records in the response.

    *)
}
Sourcetype nonrec error = [
  1. | `ClientTimeoutException of ClientTimeoutException.t
  2. | `ConstraintViolationException of ConstraintViolationException.t
  3. | `ExpiredStreamException of ExpiredStreamException.t
  4. | `IllegalArgumentException of IllegalArgumentException.t
  5. | `InvalidArgumentException of InvalidArgumentException.t
  6. | `InvalidParameterException of InvalidParameterException.t
  7. | `MemoryLimitExceededException of MemoryLimitExceededException.t
  8. | `PreconditionsFailedException of PreconditionsFailedException.t
  9. | `StreamRecordsNotFoundException of StreamRecordsNotFoundException.t
  10. | `ThrottlingException of ThrottlingException.t
  11. | `TooManyRequestsException of TooManyRequestsException.t
  12. | `UnsupportedOperationException of UnsupportedOperationException.t
  13. | `Unknown_operation_error of string * string option
]
Sourceval make : ?lastEventId:??? -> ?lastTrxTimestampInMillis:??? -> ?format:??? -> ?records:??? -> ?totalRecords:??? -> unit -> t
Sourceval error_of_json : string -> Yojson.Safe.t -> [> `ClientTimeoutException of ClientTimeoutException.t | `ConstraintViolationException of ConstraintViolationException.t | `ExpiredStreamException of ExpiredStreamException.t | `IllegalArgumentException of IllegalArgumentException.t | `InvalidArgumentException of InvalidArgumentException.t | `InvalidParameterException of InvalidParameterException.t | `MemoryLimitExceededException of MemoryLimitExceededException.t | `PreconditionsFailedException of PreconditionsFailedException.t | `StreamRecordsNotFoundException of StreamRecordsNotFoundException.t | `ThrottlingException of ThrottlingException.t | `TooManyRequestsException of TooManyRequestsException.t | `Unknown_operation_error of string * string option | `UnsupportedOperationException of UnsupportedOperationException.t ]
Sourceval error_of_xml : string -> Awso.Xml.t -> [> `ClientTimeoutException of ClientTimeoutException.t | `ConstraintViolationException of ConstraintViolationException.t | `ExpiredStreamException of ExpiredStreamException.t | `IllegalArgumentException of IllegalArgumentException.t | `InvalidArgumentException of InvalidArgumentException.t | `InvalidParameterException of InvalidParameterException.t | `MemoryLimitExceededException of MemoryLimitExceededException.t | `PreconditionsFailedException of PreconditionsFailedException.t | `StreamRecordsNotFoundException of StreamRecordsNotFoundException.t | `ThrottlingException of ThrottlingException.t | `TooManyRequestsException of TooManyRequestsException.t | `Unknown_operation_error of string * string option | `UnsupportedOperationException of UnsupportedOperationException.t ]
Sourceval error_to_json : error -> Yojson.Safe.t
Sourceval to_value : t -> [> `Structure of (string * [> `Integer of Integer.t | `List of [> `Structure of (string * [> `Boolean of Boolean.t | `Long of Long.t | `Map of ([> `String of String_.t ] * [> `String of String_.t ]) list | `String of String_.t | `Structure of (string * [> `String of String_.t ]) list ]) list ] list | `Long of Long.t | `Map of ([> `String of String_.t ] * [> `String of String_.t ]) list | `String of String_.t ]) list ]
Sourceval to_query : t -> Awso.Client.Query.t
Sourceval of_xml : Awso.Xml.t -> t
Sourceval of_string : string -> t
Sourceval of_json : Yojson.Safe.t -> t
Sourceval to_json : t -> Yojson.Safe.t