In response to a first programmatic request, metadata indicating that a first isolated read channel of a real-time category has been associated with a first target stream is stored at a stream management service. In response to another request, metadata indicating that a second isolated read channel of a non-real-time category has been associated with a second target stream is stored. In response to a read request indicating the first channel or the second channel, one or more data records of the corresponding target streams are provided.

In response to a first programmatic request, metadata indicating that a first isolated read channel of a real-time category has been associated with a first target stream is stored at a stream management service. In response to another request, metadata indicating that a second isolated read channel of a non-real-time category has been associated with a second target stream is stored. In response to a read request indicating the first channel or the second channel, one or more data records of the corresponding target streams are provided.

The present disclosure provides a data processing method and apparatus, an electronic device and a readable storage medium, and relates to the field of intelligent transportation technologies. The data processing method includes: acquiring a light-state data stream of a signal machine, the light-state data stream including a plurality of light-state data frames arranged in chronological order; determining a target light-state data frame in the light-state data stream and a target time of the target light-state data frame; acquiring a timing scheme of the signal machine; and generating, according to the timing scheme and the target light-state data frame, at least one light-state data frame at a time before and/or after the target time.

In one aspect, a method performed by a network node for predicting a probability of state change of a node (e.g., a fog node) in a network is provided. The network node determines a set of weights based on attributes of the node. The network node estimates the probability of state change of the node using the determined set of weights and a set of one or more attribute values related to the node where determining the set of weights includes maximizing an evaluation value associated to the node.

In one aspect, a method performed by a network node for predicting a probability of state change of a node (e.g., a fog node) in a network is provided. The network node determines a set of weights based on attributes of the node. The network node estimates the probability of state change of the node using the determined set of weights and a set of one or more attribute values related to the node where determining the set of weights includes maximizing an evaluation value associated to the node.

Distributed network address discovery in non-uniform node networks can be performed. Regarding a client request for a service, network management component (NMC) can determine a network address space associated with a client based on a network identifier associated with the client or a node identifier. NMC can determine a group of candidate nodes (CN group) from a group of nodes based on network addresses associated with nodes of the node group and the network address space. NMC can determine a group of available candidate nodes (ACN group), from the CN group, available and able to process the request and perform the service based on operational statuses associated with the nodes of the CN group or services associated with those nodes. From the ACN group, NMC can determine a ranked list of network addresses associated with available nodes that can process the request based on defined service performance criteria.

Examples relate to maintaining consistent cluster data across a cluster in a network. A computing system may receive a first signature of a first state of the cluster data present at a leader gateway and a plurality of signatures of a plurality of states of the cluster data present at a plurality of member network devices of the cluster. The cluster may include a plurality of gateways including the leader gateway and a plurality of member gateways. The member network devices may include the plurality of member gateways and a plurality of interconnecting network devices. In response to determining that a signature of the plurality of signatures received from one of the member network devices is different from the first signature, the computing system may send a message to one of the plurality of gateways to update the cluster data at the member network device to represent the first state.

It aims to make it possible to readily and rapidly scale up the server which executes one application.

In a computer system which includes one or more compute server(s) which each has an application container which executes the one application and a management server which manages the compute server(s), the management server is configured to, in a case of increasing the number of the compute servers which each has the execution unit which executes the one application, specify a logic unit that a data unit that the execution unit of an existing compute server utilizes upon execution of an application is stored, and in a case where the execution unit of a newly added computer server executes the application, set the newly added compute server so as to refer to the specified logic unit.

It aims to make it possible to readily and rapidly scale up the server which executes one application.

In a computer system which includes one or more compute server(s) which each has an application container which executes the one application and a management server which manages the compute server(s), the management server is configured to, in a case of increasing the number of the compute servers which each has the execution unit which executes the one application, specify a logic unit that a data unit that the execution unit of an existing compute server utilizes upon execution of an application is stored, and in a case where the execution unit of a newly added computer server executes the application, set the newly added compute server so as to refer to the specified logic unit.

Techniques for adjusting a compute capacity of a cloud computing system. In an example, a compute scaling application accesses, from a cloud computing system, a compute capacity indicating a number of allocated compute instances of a cloud computing system and usage metrics indicating pending task requests in a queue of the cloud computing system. The compute scaling application determines, for the cloud computing system, a compute scaling adjustment by applying a machine learning model to the compute capability of the cloud computing system and the usage metrics. The compute scaling adjustment indicates an adjustment to a number of compute instances of the cloud computing system. The compute scaling application provides the compute scaling adjustment to the cloud computing system. The cloud computing system adjusts a number of allocated compute instances.