vertice_import.scala

      val configJanus = new PropertiesConfiguration(configJanusPath)
      val graph = JanusGraphFactory.open(configJanus)
      // create schema
      val tx = graph.buildTransaction().enableBatchLoading().start()
      while (iter.hasNext) {
        val item = iter.next()
        val key = item.getString(0)
        val value = item.getString(1)

        val productVertex = tx.addVertex(T.label, NodeConstraint.PRODUCT_LABEL)
        productVertex.property(NodeConstraint.NODE_TYPE, NodeConstraint.PRODUCT)
        productVertex.property("shop_id", shopID)
        productVertex.property("ref_id", refID)
      }
      try {
        tx.commit()
        logger.info("Add attributes")
      }
      catch {
        case e: Exception =>
          tx.rollback()
          logger.error("Error to commit")
      }
      finally {
        tx.close()
        graph.close()
      }