code: def create(self, index, doc_type, body, id=None, **query_params):
          
          query_params['op_type'] = 'create'
          result = yield self.index(index, doc_type, body, id=id, params=query_params)
          returnValue(result)
docs: Adds a typed JSON document in a specific index, making it searchable.
          Behind the scenes this method calls index(..., op_type='create')
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-index_.html>`_
          :param index: The name of the index
          :param doc_type: The type of the document
          :param body: The document
          :param id: Document ID
          :arg consistency: Explicit write consistency setting for the operation,
              valid choices are: 'one', 'quorum', 'all'
          :arg op_type: Explicit operation type, default 'index', valid choices
              are: 'index', 'create'
          :arg parent: ID of the parent document
          :arg refresh: Refresh the index after performing the operation
          :arg routing: Specific routing value
          :arg timeout: Explicit operation timeout
          :arg timestamp: Explicit timestamp for the document
          :arg ttl: Expiration time for the document
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'