Aspects discussed herein relate to systems, apparatuses, and methods for providing content distribution via a breadth-first approach for peer-to-peer file sharing in a temporary ad hoc mesh network. For example, a peer-to-peer orchestrator may receive requests for the same asset from multiple mobile devices, determine which of the mobile devices are likely to travel along the same route at the same time, group them together and cause transmission of different asset parts of the requested asset to different mobile devices in the group. If the mobile devices in the group lose connection with the peer-to-peer orchestrator, they may form an ad hock mesh network and retrieve asset parts from one another. If the group reconnects with a peer-to-peer orchestrator, additional asset parts of the asset may be transmitted to the group and the process may repeat so that each mobile device may obtain each of the asset parts.

Disclosed are a storage system, and a method and an apparatus for allocating storage resources. In the storage system, a target management node allocates a target storage node to a monitoring device according to a first storage request; the target storage node allocates a target storage volume to the monitoring device according to a second storage request, allocates a target block group from the target storage volume to the monitoring device, acquires monitoring data in the form of a data stream from the monitoring device, and stores the monitoring data in the target block group. The storage system may select a management node from a management cluster to allocate a storage node to a monitoring device, and the storage node may allocate a storage position to the monitoring device. The storage position that is allocated to monitoring data can be determined by the management node and the storage node hierarchically.

The disclosed computer-implemented method includes accessing cluster hardware information that identifies at least two different types of storage media within a cluster and provides an indication of a respective amount of data throughput for each identified type of storage media. The method next includes accessing popularity information for digital content that is to be stored in the cluster. The popularity information indicates how often the digital content is predicted to be accessed over a specified future period of time. The method also includes allocating the digital content on the different types of storage media within the cluster according to the popularity information. Accordingly, digital content predicted to have higher popularity is placed on storage media types with higher throughput amounts, and digital content predicted to have lower popularity is placed on storage media types with lower throughput amounts. Various other methods, systems, and computer-readable media are also disclosed.

A computer-implemented method and computer program product for autoscaling a streaming platform in an event-driven microservice architecture. Upon a new consumer being added to a consumer group, the streaming platform triggers a rebalance phase if the number of the consumers in the consumer group is less than the number of the partitions and assign a new partition if the number of the consumers in the consumer group is greater than the number of the partitions. Upon a consumer being removed from a consumer group, in response to determining that the number of partitions is greater than the number of consumers, the streaming platform stops message publishing to a partition that is consumed by the consumer, allows remaining messages in the partition to be consumed, and deletes the partition in response to determining that all the remaining messages are consumed.

A method for determining a media server and a sever are provided. In the method, a live streaming access request from a target account is received; an audience number type of an anchor account in the live streaming room is determined; a target media server matching the audience number type is determined; and a live video stream in the live streaming room is transmitted, based on the target media server, to a terminal from which the target account is logged in.

Cache management techniques are described for a content distribution network (CDN), for example, a video on demand (VOD) system supporting user requests and delivery of video content. A preferred cache size may be calculated for one or more cache devices in the CDN, for example, based on a maximum cache memory size, a bandwidth availability associated with the CDN, and a title dispersion calculation determined by the user requests within the CDN. After establishing the cache with a set of assets (e.g., video content), an asset replacement algorithm may be executed at one or more cache devices in the CDN. When a determination is made that a new asset should be added to a full cache, a multi-factor comparative analysis may be performed on the assets currently residing in the cache, comparing the popularity and size of assets and combinations of assets, along with other factors to determine which assets should be replaced in the cache device.

A content distribution server, including a central server and a plurality of edge servers. The central server may be configured to obtain popularity ranking information of the video files according to video file requesting history of user terminals, and obtain sections of multiple video files based on the popularity ranking information from a content server and transmit the sections to the edge server. The plurality of edge servers may include a file caching server and a mobile edge computing server of a user terminal, and each of the edge server(s) may be configured to cache sections of the multiple video files which are received from the central server, and send a video file requested by the user terminal to the user terminal.

A streaming media live broadcast method for a load balancing layer includes: receiving a live broadcast request from a terminal, the live broadcast request including an up-streaming request or a down-streaming request; selecting a streaming media server from a plurality of streaming media servers; and forwarding the live broadcast request to the selected streaming media server to cause the selected streaming media server to provide a live broadcast service according to the broadcast request.

Data is obtained from a data stream managed by a data stream service prior to expiration of a data retention time. The data is archived to a data store distinct from the data stream service (e.g., in a full or compacted mode). Access to the archived data is provided via a proxy that intercepts requests directed to the streaming service. For example, the proxy or a redirect utility for the proxy may intercept a query, and for data specified in the query that is past the retention expiration time, the data is retrieved from the data store. For data specified in the query that has not yet expired, the data is retrieved from the data stream service. In either case, the system responds to the query with the retrieved data according to the access interface of the data stream service (e.g., injecting the retrieved data into a data stream).

Methods, systems, and apparatuses are described for fault tolerant network storage and delivery of recorded content. Two or more network digital video recorders may each receive a plurality of requests to record, archive, and/or play back content items, such as television programs. Each network digital video recorder may receive capacity reports of statistics such as storage and/or bandwidth from one or more other network digital video recorders. At least one of the network digital video recorders may determine whether, based on a network capacity, to record, archive, and/or playback content items. The methods, systems, and apparatuses may accommodate equipment failures that lead to partitions between network digital video recorders.