connectordb/_stream.py
def export(self, directory):
        """Exports the stream to the given directory. The directory can't exist. 
        You can later import this device by running import_stream on a device.
        """
        if os.path.exists(directory):
            raise FileExistsError(
                "The stream export directory already exists")

        os.mkdir(directory)

        # Write the stream's info
        with open(os.path.join(directory, "stream.json"), "w") as f:
            json.dump(self.data, f)

        # Now write the stream's data
        # We sort it first, since older versions of ConnectorDB had a bug
        # where sometimes datapoints would be returned out of order.
        self[:].sort().writeJSON(os.path.join(directory, "data.json"))

        # And if the stream is a downlink, write the downlink data
        if self.downlink:
            self(i1=0, i2=0, downlink=True).sort().writeJSON(os.path.join(directory, "downlink.json"))
def export(self, directory):
        if os.path.exists(directory):
            raise FileExistsError(
                "The stream export directory already exists")

        os.mkdir(directory)

        # Write the stream's info
        with open(os.path.join(directory, "stream.json"), "w") as f:
            json.dump(self.data, f)

        # Now write the stream's data
        # We sort it first, since older versions of ConnectorDB had a bug
        # where sometimes datapoints would be returned out of order.
        self[:].sort().writeJSON(os.path.join(directory, "data.json"))

        # And if the stream is a downlink, write the downlink data
        if self.downlink:
            self(i1=0, i2=0, downlink=True).sort().writeJSON(os.path.join(directory, "downlink.json"))
def export ( self , directory ) : if os . path . exists ( directory ) : raise FileExistsError ( "The stream export directory already exists" ) os . mkdir ( directory ) # Write the stream's info with open ( os . path . join ( directory , "stream.json" ) , "w" ) as f : json . dump ( self . data , f ) # Now write the stream's data # We sort it first, since older versions of ConnectorDB had a bug # where sometimes datapoints would be returned out of order. self [ : ] . sort ( ) . writeJSON ( os . path . join ( directory , "data.json" ) ) # And if the stream is a downlink, write the downlink data if self . downlink : self ( i1 = 0 , i2 = 0 , downlink = True ) . sort ( ) . writeJSON ( os . path . join ( directory , "downlink.json" ) )
Exports the stream to the given directory. The directory can't exist. 
        You can later import this device by running import_stream on a device.
Exports the stream to the given directory . The directory can t exist . You can later import this device by running import_stream on a device .