A software architecture for the analysis of large sets of data streams in cloud infrastructures