@flow.EventHandler()
  def ProcessMessage(self, message=None, event=None):
    _ = event
    vfs_urn = message.payload

    vfs_fd = aff4.FACTORY.Open(vfs_urn, mode="rw", token=self.token)
    filestore_fd = aff4.FACTORY.Create(filestore.FileStore.PATH, "FileStore",
                                       mode="w", token=self.token)
    filestore_fd.AddFile(vfs_fd)
    vfs_fd.Flush(sync=False)
Process the new file and add to the file store.
dataset/ETHPy150Open google/grr/grr/lib/flows/general/transfer.py/FileStoreCreateFile.ProcessMessage