Datapoints.Ingest

datapoints := []*v1.Modis{
  v1.Modis_builder{
    Time:        timestamppb.New(time.Now()),
    GranuleName: proto.String("Granule 1"),
  }.Build(),
  v1.Modis_builder{
    Time:        timestamppb.New(time.Now().Add(-5 * time.Hour)),
    GranuleName: proto.String("Past Granule 2"),
  }.Build(),
}

ingestResponse, err := client.Datapoints.Ingest(ctx,
    collectionID,
    &datapoints,
    false,
)

func (datapointClient) Ingest(
    ctx context.Context,
    collectionID uuid.UUID,
    datapoints any,
    allowExisting bool,
) (*datasets.IngestResponse, error)

Ingest data points into a collection.

Parameters

uuid.UUID

The id of the collection

*[]proto.Message

The datapoints to ingest

bool

Datapoint fields are used to generate a deterministic unique UUID for each datapoint in a collection. Duplicate data points result in the same ID being generated. If allowExisting is true, ingest will skip those datapoints, since they already exist. If allowExisting is false, ingest will raise an error if any of the generated datapoint IDs already exist.

Returns

An IngestResponse with NumCreated, NumExisting, and DatapointIDs. DatapointIDs includes the IDs of ingested datapoints and, when allowExisting is true, the IDs of datapoints that already existed.

datapoints := []*v1.Modis{
  v1.Modis_builder{
    Time:        timestamppb.New(time.Now()),
    GranuleName: proto.String("Granule 1"),
  }.Build(),
  v1.Modis_builder{
    Time:        timestamppb.New(time.Now().Add(-5 * time.Hour)),
    GranuleName: proto.String("Past Granule 2"),
  }.Build(),
}

ingestResponse, err := client.Datapoints.Ingest(ctx,
    collectionID,
    &datapoints,
    false,
)

Errors

found existing datapoints with same id

If allowExisting is false and any datapoints already exist.

Python

Go

Parameters

Returns

Errors

​Parameters

​Returns

​Errors

Parameters

Returns

Errors