def METHOD_NAME(
    self,
    device_name: str,
    stream_name: str,
    media_type: str,
    kms_key_id: str,
    data_retention_in_hours: int,
    tags: Dict[str, str],
) -> str:
    streams = [_ for _ in self.streams.values() if _.stream_name == stream_name]
    if len(streams) > 0:
        raise ResourceInUseException(f"The stream {stream_name} already exists.")
    stream = Stream(
        self.account_id,
        self.region_name,
        device_name,
        stream_name,
        media_type,
        kms_key_id,
        data_retention_in_hours,
        tags,
    )
    self.streams[stream.arn] = stream
    return stream.arn