Stay organized with collections
Save and categorize content based on your preferences.
Full name: projects.locations.featureOnlineStores.featureViews.directWrite
Bidirectional streaming RPC to directly write to feature values in a feature view. Requests may not have a one-to-one mapping to responses and responses may be returned out-of-order to reduce latency.
Endpoint
post
https://{service-endpoint}/v1beta1/{featureView}:directWrite
The error only applies to the listed data keys - the stream will remain open for further [FeatureOnlineStoreService.FeatureViewDirectWriteRequest][] requests.
Partial failures (e.g. if the first 10 keys of a request fail, but the rest succeed) from a single request may result in multiple responses - there will be one response for the successful request keys and one response for the failing request keys.
The feature timestamp to store with this value. If not set, then the feature Store server will generate a timestamp when it receives the write request.
Uses RFC 3339, where generated output will always be Z-normalized and uses 0, 3, 6 or 9 fractional digits. Offsets other than "Z" are also accepted. Examples: "2014-10-02T15:01:23Z", "2014-10-02T15:01:23.045123456Z" or "2014-10-02T15:01:23+05:30".
Uses RFC 3339, where generated output will always be Z-normalized and uses 0, 3, 6 or 9 fractional digits. Offsets other than "Z" are also accepted. Examples: "2014-10-02T15:01:23Z", "2014-10-02T15:01:23.045123456Z" or "2014-10-02T15:01:23+05:30".
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-07-31 UTC."],[],[],null,["# Method: featureViews.directWrite\n\n**Full name**: projects.locations.featureOnlineStores.featureViews.directWrite\n\nBidirectional streaming RPC to directly write to feature values in a feature view. Requests may not have a one-to-one mapping to responses and responses may be returned out-of-order to reduce latency. \n\n### Endpoint\n\npost `https:``/``/{service-endpoint}``/v1beta1``/{featureView}:directWrite` \nWhere `{service-endpoint}` is one of the [supported service endpoints](/vertex-ai/docs/reference/rest#rest_endpoints).\n\n### Path parameters\n\n`featureView` `string` \nFeatureView resource format `projects/{project}/locations/{location}/featureOnlineStores/{featureOnlineStore}/featureViews/{featureView}`\n\n### Request body\n\nThe request body contains data with the following structure:\nFields `dataKeyAndFeatureValues[]` `object (`[DataKeyAndFeatureValues](/vertex-ai/docs/reference/rest/v1beta1/projects.locations.featureOnlineStores.featureViews/directWrite#DataKeyAndFeatureValues)`)` \nRequired. The data keys and associated feature values. \n\n### Response body\n\nResponse message for [FeatureOnlineStoreService.FeatureViewDirectWrite](/vertex-ai/docs/reference/rest/v1beta1/projects.locations.featureOnlineStores.featureViews/directWrite#google.cloud.aiplatform.v1beta1.FeatureOnlineStoreService.FeatureViewDirectWrite).\n\nIf successful, the response body contains data with the following structure:\nFields `status` `object (`[Status](/vertex-ai/docs/reference/rest/Shared.Types/ListOperationsResponse#Status)`)` \nResponse status for the keys listed in [FeatureViewDirectWriteResponse.write_responses](/vertex-ai/docs/reference/rest/v1beta1/projects.locations.featureOnlineStores.featureViews/directWrite#body.FeatureViewDirectWriteResponse.FIELDS.write_responses).\n\nThe error only applies to the listed data keys - the stream will remain open for further \\[FeatureOnlineStoreService.FeatureViewDirectWriteRequest\\]\\[\\] requests.\n\nPartial failures (e.g. if the first 10 keys of a request fail, but the rest succeed) from a single request may result in multiple responses - there will be one response for the successful request keys and one response for the failing request keys.\n`writeResponses[]` `object (`[WriteResponse](/vertex-ai/docs/reference/rest/v1beta1/projects.locations.featureOnlineStores.featureViews/directWrite#WriteResponse)`)` \nDetails about write for each key. If status is not OK, [WriteResponse.data_key](/vertex-ai/docs/reference/rest/v1beta1/projects.locations.featureOnlineStores.featureViews/directWrite#WriteResponse.FIELDS.data_key) will have the key with error, but [WriteResponse.online_store_write_time](/vertex-ai/docs/reference/rest/v1beta1/projects.locations.featureOnlineStores.featureViews/directWrite#WriteResponse.FIELDS.online_store_write_time) will not be present. \n\nDataKeyAndFeatureValues\n-----------------------\n\nA data key and associated feature values to write to the feature view.\nFields `dataKey` `object (`[FeatureViewDataKey](/vertex-ai/docs/reference/rest/v1beta1/FeatureViewDataKey)`)` \nThe data key.\n`features[]` `object (`[Feature](/vertex-ai/docs/reference/rest/v1beta1/projects.locations.featureOnlineStores.featureViews/directWrite#Feature)`)` \nList of features to write. \n\nFeature\n-------\n\nfeature name \\& value pair.\nFields `name` `string` \nfeature short name. \n`data_oneof` `Union type` \nFeature value data to write. `data_oneof` can be only one of the following:\n`value` `object (`[FeatureValue](/vertex-ai/docs/reference/rest/v1beta1/FeatureValue)`)` \nfeature value. A user provided timestamp may be set in the `FeatureValue.metadata.generate_time` field.\n`valueAndTimestamp` `object (`[FeatureValueAndTimestamp](/vertex-ai/docs/reference/rest/v1beta1/projects.locations.featureOnlineStores.featureViews/directWrite#FeatureValueAndTimestamp)`)` \nfeature value and timestamp. \n\nFeatureValueAndTimestamp\n------------------------\n\nfeature value and timestamp.\nFields `value` `object (`[FeatureValue](/vertex-ai/docs/reference/rest/v1beta1/FeatureValue)`)` \nThe feature value.\n`timestamp` `string (`[Timestamp](https://protobuf.dev/reference/protobuf/google.protobuf/#timestamp)` format)` \nThe feature timestamp to store with this value. If not set, then the feature Store server will generate a timestamp when it receives the write request.\n\nUses RFC 3339, where generated output will always be Z-normalized and uses 0, 3, 6 or 9 fractional digits. Offsets other than \"Z\" are also accepted. Examples: `\"2014-10-02T15:01:23Z\"`, `\"2014-10-02T15:01:23.045123456Z\"` or `\"2014-10-02T15:01:23+05:30\"`. \n\nWriteResponse\n-------------\n\nDetails about the write for each key.\nFields `dataKey` `object (`[FeatureViewDataKey](/vertex-ai/docs/reference/rest/v1beta1/FeatureViewDataKey)`)` \nWhat key is this write response associated with.\n`onlineStoreWriteTime` `string (`[Timestamp](https://protobuf.dev/reference/protobuf/google.protobuf/#timestamp)` format)` \nWhen the feature values were written to the online store. If [FeatureViewDirectWriteResponse.status](/vertex-ai/docs/reference/rest/v1beta1/projects.locations.featureOnlineStores.featureViews/directWrite#body.FeatureViewDirectWriteResponse.FIELDS.status) is not OK, this field is not populated.\n\nUses RFC 3339, where generated output will always be Z-normalized and uses 0, 3, 6 or 9 fractional digits. Offsets other than \"Z\" are also accepted. Examples: `\"2014-10-02T15:01:23Z\"`, `\"2014-10-02T15:01:23.045123456Z\"` or `\"2014-10-02T15:01:23+05:30\"`."]]
