Some embodiments provide a simplified mechanism to deploy and control a multi-segmented application by using application-based manifests that express how application segments of the multi-segment application are to be defined or modified, and how the communication profiles between these segments. In some embodiments, these manifests are application specific. Also, in some embodiments, deployment managers in a software defined datacenter (SDDC) provide these manifests as templates to administrators, who can use these templates to express their intent when they are deploying multi-segment applications in the datacenter. Application-based manifests can also be used to control previously deployed multi-segmented applications in the SDDC. Using such manifests would enable the administrators to be able to manage fine grained micro-segmentation rules based on endpoint and network attributes.

A processor implemented method for monitoring the performance of a message queue for communication between processes is described. The method includes, by an initiating process, publishing a trigger message to a first topic in the message queue, wherein the trigger message identifies one or more performance metrics and at least two processes that communicate via the message queue. The method further includes, by one or more of the at least two processes, retrieving the trigger message from the first topic in the message queue; performing a measurement on one or more messages exchanged between the processes over the message queue, wherein the measurement determines the one or more performance metrics; and publishing the one or more determined performance metrics to a second topic in the message queue. The method also includes, at a receiving process, retrieving the published performance metrics from the second topic in the message queue.

A method includes performing, by a processor: receiving a message, a message identification, and a hash value of a map specifying a layout of the message, comparing the hash value with a reference hash value associated with the message identification, requesting the map responsive to a mismatch between the hash value and the reference hash value, receiving the map, and decoding the message based on the map.

A machine learning system including a continuous embedding output layer is provided. Whereas traditional machine language translation or generation models utilize an output layer that include an single output for each word in the output vocabulary V, the present machine learning system includes a continuous embedding output layer that stores continuous vectors mapped to an m-dimensional vector space, where m is less than V. Accordingly, the present machine learning system processes an input string to produce an output vector and then searches for the continuous vector within the vector space that most closely corresponding to the output vector via, for example, a k-nearest neighbor algorithm. The system then outputs the output string corresponding to the determined continuous vector. The present system can be trained utilizing a cosine-based loss function.

An MPI collective operation carried out in a fabric of network elements by transmitting MPI messages from all the initiator processes in an initiator node to designated ones of the responder processes in respective responder nodes. Respective payloads of the MPI messages are combined in a network interface device of the initiator node to form an aggregated MPI message. The aggregated MPI message is transmitted through the fabric to network interface devices of responder nodes, disaggregating the aggregated MPI message into individual messages, and distributing the individual messages to the designated responder node processes.

The present disclosure relates to utilizing a real-time event data reporting system that makes real-time and near-real-time monitoring and reporting possible in edge devices. For example, in various instances, the real-time event data reporting system embeds services within traditional event data collectors of edge devices to obtain, organize, and publish event data for local computing devices in real time utilizing in-memory storage. Additionally, the real-time event data reporting system further processes the published event data to generate aggregated data that is persisted to a persistence storage. In this manner, the real-time reporting system efficiently and accurately provides event data reports to client devices with processed metric data in real time, or in near-real time when utilizing additional fallback safeguards. Indeed, the real-time reporting system provides a highly available, fault-tolerant, distributed, scalable, and efficient mechanism for collecting and managing various metrics from services in edge or cloud environments.

Provided are an abnormal request processing method and apparatus, an electronic device and a storage medium. The method includes: acquiring a target request within a preset time period, where the target request includes a network resource identifier; querying a first queue; in the case where the first queue does not include a first request matching the network resource identifier, querying a second queue; in the case where the second queue includes a second request matching the network resource identifier, updating request data of the second request matching the network resource identifier; and at an end of the preset time period, determining request data of the target request according to the first queue or the second queue, and in the case where the request data of the target request meets a first preset condition, determining the target request to be an abnormal request.

A system and a method for routing a message to an application over a connection oriented session in a Kafka messaging platform environment are provided. The method includes: acquiring a plurality of partitions from the Kafka messaging platform; designating a first partition from among the plurality of partitions as a sticky partition; generating a plurality of routing keys that are configured to route to the sticky partition; receiving a subscription from a service that corresponds to a first application; transmitting, to the first application, a first routing key that identifies the subscription from among the plurality of routing keys; and receiving messages from Kafka services that are routed by the first routing key to the first application. For any particular application or set of applications, a plurality of connection oriented sessions may be used to achieve load balancing and high availability.

Adapted positioning information is provided towards at least one consuming application regarding a plurality of objects. In a first step, the position of at least one specific object is detected using at least one sensor of a sensor layer or functionality, thereby generating at least one piece of preliminary positioning information. In a second step, subsequent to the first step, a positioning middleware functionality generates at least one piece of adapted positioning information, based on the at least one piece of preliminary positioning information, and based on a priori knowledge. In a third step, subsequent to the second step, the at least one piece of adapted positioning information is provided to the at least one consuming application.

This application discloses a system architecture for implementing DDS communication based on AUTOSAR, a communication method, and a device, which may be applied to an intelligent agent (for example, an intelligent vehicle, an intelligent connected vehicle, or an autonomous vehicle) in intelligent driving.