Systems, apparatus, and methods for edge data prioritization

Abstract

Methods, apparatus, systems and articles of manufacture are disclosed for edge data prioritization. An example apparatus includes at least one memory, instructions, and processor circuitry to at least one of execute or instantiate the instructions to identify an association of a data packet with a data stream based on one or more data stream parameters included in the data packet corresponding to the data stream, the data packet associated with a first priority, execute a model based on the one or more data stream parameters to generate a model output, determine a second priority of at least one of the data packet or the data stream based on the model output, the model output indicative of an adjustment of the first priority to the second priority, and cause transmission of at least one of the data packet or the data stream based on the second priority.

What is claimed is: 
     
       1. An apparatus to prioritize data traffic in an edge network environment, the apparatus comprising:
 at least one memory; 
 instructions; and 
 processor circuitry to at least one of execute or instantiate the instructions to:
 identify an association of a data packet with a data stream based on one or more data stream parameters included in the data packet, the one or more data stream parameters corresponding to the data stream, the data packet associated with a first priority; 
 select a model based on the association of the data packet with the data stream; 
 execute the model using information corresponding to at least one of the data packet or the data stream to generate a model output; 
 determine a second priority of at least one of the data packet or the data stream based on the model output, the second priority different than the first priority; and 
 cause transmission of at least one of the data packet or the data stream based on the second priority. 
 
 
     
     
       2. The apparatus of  claim 1 , wherein the data packet is a first data packet, the data stream is a first data stream, and, based on a determination that a second data packet with a third priority is not associated with the first data stream or one or more second data streams, the processor circuitry is to cause transmission of the second data packet based on the third priority. 
     
     
       3. The apparatus of  claim 1 , wherein the processor circuitry is to:
 determine whether a threshold has been satisfied based on a number of obtained data packets of the data stream; and 
 based on the threshold being satisfied, re-train the model based on the one or more data stream parameters. 
 
     
     
       4. The apparatus of  claim 1 , wherein the one or more data stream parameters are one or more first data stream parameters, and the processor circuitry is to:
 identify one or more source data stream parameters including at least one of a source service or a source appliance associated with the data stream; 
 identify one or more target data stream parameters including at least one of a target service, a target appliance, a first identifier of the target service, or a second identifier of the target appliance associated with the data stream; 
 identify a data type of payload data of the data packet, the model based on at least one of the one or more data stream parameters, the one or more target data stream parameters, or the data type; and 
 cause storage of at least one of the one or more source data stream parameters, the one or more target data stream parameters, or the data type as second data stream parameters, the second data stream parameters including the one or more first data stream parameters. 
 
     
     
       5. The apparatus of  claim 1 , wherein the processor circuitry is to:
 identify a definition data stream parameter including a data type definition or a formula definition; 
 after a first identification of the definition data stream parameter as the data type definition, determine one or more bit locations of a bit stream of the data packet to extract, the execution of the model based on the one or more bit locations to extract; and 
 after a second identification of the definition data stream parameter as the formula definition based on a compression or encryption of the bit stream, determine a decompression technique or a decryption technique, the execution of the model based on the decompression technique or the decryption technique. 
 
     
     
       6. The apparatus of  claim 1 , wherein the association is a first association, and the processor circuitry is to:
 identify a second association of the one or more data stream parameters and a decryption technique; and 
 decrypt the one or more data stream parameters in a trusted execution environment, the execution of the model based on the decryption of the one or more data stream parameters. 
 
     
     
       7. The apparatus of  claim 1 , wherein the association is a first association, the data packet is a first data packet, the data stream is a first data stream, the model is a first model, the model output is a first model output, and the processor circuitry is to:
 identify a second association of the first data stream and a second data stream; 
 execute a second model based on the one or more data stream parameters to generate a second model output, the second model associated with the second data stream; and 
 determine a third priority of a second data packet based on the second model output, the second data packet obtained after the first data packet. 
 
     
     
       8. An apparatus to prioritize data traffic in an edge network environment, the apparatus comprising:
 means for identifying an association of a data packet with a data stream based on one or more data stream parameters included in the data packet, the one or more data stream parameters corresponding to the data stream, the data packet associated with a first priority; 
 means for executing a model using information corresponding to at least one of the data packet or the data stream to generate a model output, the model selected based on the association of the data packet with the data stream; 
 means for adjusting the first priority of the data packet to a second priority of at least one of the data packet based on the model output, the second priority different than the first priority; and 
 means for transmitting at least one of the data packet or the data stream based on the second priority. 
 
     
     
       9. The apparatus of  claim 8 , wherein the data packet is a first data packet, the data stream is a first data stream, and, based on a determination that a second data packet with a third priority is not associated with the first data stream or one or more second data streams, the means for transmitting is to transmit the second data packet based on the third priority. 
     
     
       10. The apparatus of  claim 8 , wherein the means for identifying is to determine whether a threshold has been satisfied based on a number of obtained data packets of the data stream, and further including means for training the model based on the one or more data stream parameters based on a determination that the threshold has been satisfied. 
     
     
       11. The apparatus of  claim 8 , wherein the one or more data stream parameters are one or more first data stream parameters, and further including means for configuring the data stream, the means for configuring to:
 identify one or more source data stream parameters including at least one of a source service or a source appliance associated with the data stream; 
 identify one or more target data stream parameters including at least one of a target service, a target appliance, a first identifier of the target service, or a second identifier of the target appliance associated with the data stream; 
 identify a data type of payload data of the data packet, the model based on at least one of the one or more data stream parameters, the one or more target data stream parameters, or the data type; and 
 cause storage of at least one of the one or more source data stream parameters, the one or more target data stream parameters, or the data type as second data stream parameters, the second data stream parameters including the one or more first data stream parameters, the means for configuring to configure the data stream based on the at least one of the one or more source data stream parameters, the one or more target data stream parameters, or the data type. 
 
     
     
       12. The apparatus of  claim 8 , further including means for configuring the data stream, the means for configuring to:
 identify a definition data stream parameter including a data type definition or a formula definition; 
 after a first identification of the definition data stream parameter as the data type definition, determine one or more bit locations of a bit stream of the data packet to extract, the execution of the model based on the one or more bit locations to extract; and 
 after a second identification of the definition data stream parameter as the formula definition based on a compression or encryption of the bit stream, determine a decompression technique or a decryption technique, the execution of the model based on the decompression technique or the decryption technique. 
 
     
     
       13. The apparatus of  claim 8 , wherein the association is a first association, the data packet is a first data packet, the data stream is a first data stream, the model is a first model, the model output is a first model output, and wherein:
 the means for adjusting is to identify a second association of the first data stream and a second data stream; 
 the means for executing is to execute a second model based on the one or more data stream parameters to generate a second model output, the second model associated with the second data stream; and 
 the means for adjusting is to determine a third priority of a second data packet based on the second model output, the second data packet obtained after the first data packet. 
 
     
     
       14. At least one non-transitory computer readable medium comprising instructions that cause processor circuitry to at least:
 identify a data stream based on one or more data stream parameters included in a received data packet, the one or more data stream parameters corresponding to the data stream, the data packet associated with a first priority; 
 select a model based on the identified data stream; 
 execute the model using information corresponding to at least one of the data packet or the data stream to generate a model output; 
 change the first priority of the packet to a second priority based on the model output, the second priority different than the first priority; and 
 cause transmission the data packet based on the second priority. 
 
     
     
       15. The at least one non-transitory computer readable medium of  claim 14 , wherein the data packet is a first data packet, the data stream is a first data stream, and, based on a determination that a second data packet with a third priority is not associated with the first data stream or one or more second data streams, the instructions, when executed, cause the processor circuitry to cause transmission of the second data packet based on the third priority. 
     
     
       16. The at least one non-transitory computer readable medium of  claim 14 , wherein the instructions, when executed, cause the processor circuitry to:
 determine whether a threshold has been satisfied based on a number of obtained data packets of the data stream; and 
 based on the threshold being satisfied, re-train the model based on the one or more data stream parameters. 
 
     
     
       17. The at least one non-transitory computer readable medium of  claim 14 , wherein the one or more data stream parameters are one or more first data stream parameters, and the instructions, when executed, cause the processor circuitry to:
 identify one or more source data stream parameters including at least one of a source service or a source appliance associated with the data stream; 
 identify one or more target data stream parameters including at least one of a target service, a target appliance, a first identifier of the target service, or a second identifier of the target appliance associated with the data stream; 
 identify a data type of payload data of the data packet, the model based on at least one of the one or more data stream parameters, the one or more target data stream parameters, or the data type; and 
 cause storage of at least one of the one or more source data stream parameters, the one or more target data stream parameters, or the data type as second data stream parameters, the second data stream parameters including the one or more first data stream parameters. 
 
     
     
       18. The at least one non-transitory computer readable medium of  claim 14 , wherein the instructions, when executed, cause the processor circuitry to:
 identify a definition data stream parameter including a data type definition or a formula definition; 
 after a first identification of the definition data stream parameter as the data type definition, determine one or more bit locations of a bit stream of the data packet to extract, the execution of the model based on the one or more bit locations to extract; and 
 after a second identification of the definition data stream parameter as the formula definition based on a compression or encryption of the bit stream, determine a decompression technique or a decryption technique, the execution of the model based on the decompression technique or the decryption technique. 
 
     
     
       19. The at least one non-transitory computer readable medium of  claim 14 , wherein the association is a first association, and the instructions, when executed, cause the processor circuitry to:
 identify a second association of the one or more data stream parameters and a decryption technique; and 
 decrypt the one or more data stream parameters in a trusted execution environment, the execution of the model based on the decryption of the one or more data stream parameters. 
 
     
     
       20. The at least one non-transitory computer readable medium of  claim 14 , wherein the association is a first association, the data packet is a first data packet, the data stream is a first data stream, the model is a first model, the model output is a first model output, and the instructions, when executed, cause the processor circuitry to:
 identify a second association of the first data stream and a second data stream; 
 execute a second model based on the one or more data stream parameters to generate a second model output, the second model associated with the second data stream; and 
 determine a third priority of a second data packet based on the second model output, the second data packet obtained after the first data packet. 
 
     
     
       21. An apparatus to prioritize data traffic in an edge network environment, the apparatus comprising:
 processor circuitry including one or more of:
 at least one of a central processor unit, a graphic processor unit, or a digital signal processor, the at least one of the central processor unit, the graphic processor unit or the digital signal processor having control circuitry to control data movement within the processor circuitry, arithmetic and logic circuitry to perform one or more first operations corresponding to instructions, and one or more registers to store a result of the one or more first operations, the instructions in the apparatus; 
 a Field Programmable Gate Array (FPGA), the FPGA including logic gate circuitry, a plurality of configurable interconnections, and storage circuitry, the logic gate circuitry and interconnections to perform one or more second operations, the storage circuitry to store a result of the one or more second operations; or 
 Application Specific Integrated Circuitry (ASIC) including logic gate circuitry to perform one or more third operations; 
 
 the processor circuitry to perform at least one of the first operations, the second operations, or the third operations to instantiate:
 traffic interceptor circuitry to identify an association of a data packet with a data stream based on one or more data stream parameters included in the data packet, the one or more data stream parameters corresponding to the data stream, the data packet associated with a first priority; and 
 data priority generator circuitry to:
 identify a model based on the association of the data packet with the data stream; and 
 change the first priority of at least one of the data packet or the data stream to a second priority based on a model output, the second priority different than the first priority; 
 
 
 acceleration circuitry to execute the model using information corresponding to at least one of the data packet or the data stream to generate the model output; and 
 a data interface to transmit at least one of the data packet or the data stream based on the second priority. 
 
     
     
       22. The apparatus of  claim 21 , wherein the one or more data stream parameters are one or more first data stream parameters, the processor circuitry is to perform at least one of the first operations, the second operations, or the third operations to instantiate stream configuration generator circuitry to configure the data stream, and the stream configuration generator circuitry is to:
 identify one or more source data stream parameters including at least one of a source service or a source appliance associated with the data stream; 
 identify one or more target data stream parameters including at least one of a target service, a target appliance, a first identifier of the target service, or a second identifier of the target appliance associated with the data stream; 
 identify a data type of payload data of the data packet, the model based on at least one of the one or more data stream parameters, the one or more target data stream parameters, or the data type; and 
 cause storage of at least one of the one or more source data stream parameters, the one or more target data stream parameters, or the data type as second data stream parameters, the second data stream parameters including the one or more first data stream parameters, the stream configuration generator circuitry to configure the data stream based on the at least one of the one or more source data stream parameters, the one or more target data stream parameters, or the data type. 
 
     
     
       23. The apparatus of  claim 21 , wherein the processor circuitry is to perform at least one of the first operations, the second operations, or the third operations to instantiate stream configuration generator circuitry to:
 identify a definition data stream parameter including a data type definition or a formula definition; 
 after a first identification of the definition data stream parameter as the data type definition, determine one or more bit locations of a bit stream of the data packet to extract, the execution of the model based on the one or more bit locations to extract; and 
 after a second identification of the definition data stream parameter as the formula definition based on a compression or encryption of the bit stream, determine a decompression technique or a decryption technique, the execution of the model based on the decompression technique or the decryption technique. 
 
     
     
       24. The apparatus of  claim 21 , wherein the association is a first association, the data packet is a first data packet, the data stream is a first data stream, the model is a first model, the model output is a first model output, and wherein:
 the data priority generator circuitry is to identify a second association of the first data stream and a second data stream; 
 the acceleration circuitry is to execute a second model based on the one or more data stream parameters to generate a second model output, the second model associated with the second data stream; and 
 the data priority generator circuitry is to determine a third priority of a second data packet based on the second model output, the second data packet obtained after the first data packet. 
 
     
     
       25. The apparatus of  claim 1 , wherein the data stream is assigned the first priority prior to receiving the data packet.