| 摘要 |
A system for responding to requests using stream processing can include a processor configured to initiate executable operations including include receiving a server request from a server, wherein the server is configured to generate the server request responsive to a client request, generating a request identifier associated with the server request, and, responsive to the server request, sending a stream processing request derived from the server request to a first stream processing node. The stream processing request can include the request identifier. Responsive to receiving a create response message including a stream processing result and the request identifier from a second stream processing node, the stream processing result can be correlated with the server request. A write response message specifying the stream processing result can be sent to the server.
|
