• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Python core.retval函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中weightless.core.retval函数的典型用法代码示例。如果您正苦于以下问题:Python retval函数的具体用法?Python retval怎么用?Python retval使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。



在下文中一共展示了retval函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: testJoinSort

    def testJoinSort(self):
        cq = ComposedQuery('coreA')
        cq.setCoreQuery(core='coreA', query=MatchAllDocsQuery())
        cq.addMatch(dict(core='coreA', uniqueKey=KEY_PREFIX+'A'), dict(core='coreB', key=KEY_PREFIX+'B'))
        cq.addSortKey({'sortBy': 'T', 'sortDescending': False, 'core': 'coreB'})
        cq.addSortKey({'sortBy': 'S', 'sortDescending': False, 'core': 'coreA'})
        result = retval(self.dna.any.executeComposedQuery(cq))
        self.assertEqual(['A-M', 'A-MU', 'A-MQ', 'A-MQU', 'A', 'A-U', 'A-Q', 'A-QU'], [hit.id for hit in result.hits])

        cq = ComposedQuery('coreA')
        cq.setCoreQuery(core='coreA', query=MatchAllDocsQuery())
        cq.addMatch(dict(core='coreA', uniqueKey=KEY_PREFIX+'A'), dict(core='coreB', key=KEY_PREFIX+'B'))
        cq.addSortKey({'sortBy': 'T', 'sortDescending': True, 'core': 'coreB'})
        cq.addSortKey({'sortBy': 'S', 'sortDescending': False, 'core': 'coreA'})
        result = retval(self.dna.any.executeComposedQuery(cq))
        self.assertEqual(['A-MQU', 'A-MQ', 'A-MU', 'A-M', 'A', 'A-U', 'A-Q', 'A-QU'], [hit.id for hit in result.hits])

        cq = ComposedQuery('coreA')
        cq.setCoreQuery(core='coreA', query=MatchAllDocsQuery())
        cq.addMatch(dict(core='coreA', uniqueKey=KEY_PREFIX+'A'), dict(core='coreB', key=KEY_PREFIX+'B'))
        cq.addSortKey({'sortBy': 'intField', 'sortDescending': True, 'core': 'coreB'})
        cq.addSortKey({'sortBy': 'S', 'sortDescending': False, 'core': 'coreA'})
        result = retval(self.dna.any.executeComposedQuery(cq))
        self.assertEqual(['A-MQU', 'A-MQ', 'A-MU', 'A-M', 'A', 'A-U', 'A-Q', 'A-QU'], [hit.id for hit in result.hits])

        cq = ComposedQuery('coreA')
        cq.setCoreQuery(core='coreA', query=MatchAllDocsQuery())
        cq.addMatch(dict(core='coreA', uniqueKey=KEY_PREFIX+'A'), dict(core='coreB', key=KEY_PREFIX+'B'))
        cq.addSortKey({'sortBy': 'intField', 'sortDescending': True, 'core': 'coreB', 'missingValue': 20})
        cq.addSortKey({'sortBy': 'S', 'sortDescending': False, 'core': 'coreA'})
        result = retval(self.dna.any.executeComposedQuery(cq))
        self.assertEqual(['A', 'A-U', 'A-Q', 'A-QU', 'A-MQU', 'A-MQ', 'A-MU', 'A-M'], [hit.id for hit in result.hits])
开发者ID:FashtimeDotCom,项目名称:meresco-lucene,代码行数:32,代码来源:multiluceneoldtest.py


示例2: testTimeoutExceptionTriggersBackoff

    def testTimeoutExceptionTriggersBackoff(self):
        self.init(cacheTimeout=0.1, returnCachedValueInCaseOfException=True, backoffTimeout=0.1)
        def someMessageResult(*args, **kwargs):
            raise StopIteration('result')
            yield
        def someMessageTimeout(*args, **kwargs):
            raise TimeoutException()
            yield
        self.observer.methods['someMessage'] = someMessageResult
        result = retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
        self.assertEquals(['someMessage'], self.observer.calledMethodNames())
        sleep(0.11)

        self.observer.methods['someMessage'] = someMessageTimeout
        result = retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
        self.assertEquals('result', result)
        self.assertEquals(['someMessage', 'someMessage'], self.observer.calledMethodNames())
        result = retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
        self.assertEquals('result', result)
        # should be in backoff mode and not even try!
        self.assertEquals(['someMessage', 'someMessage'], self.observer.calledMethodNames())
        sleep(0.11)

        self.observer.methods['someMessage'] = someMessageResult
        result = retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
        self.assertEquals('result', result)
        self.assertEquals(['someMessage', 'someMessage', 'someMessage'], self.observer.calledMethodNames())
开发者ID:seecr,项目名称:meresco-components,代码行数:27,代码来源:timedmessagecachetest.py


示例3: testIndexingState

    def testIndexingState(self):
        self.response = dumps(dict(started=12345, count=12))
        result = retval(self.sic.indexingState())
        self.assertEqual(dict(started=12345, count=12), result)

        self.response = dumps(dict())
        result = retval(self.sic.indexingState())
        self.assertEqual(None, result)
开发者ID:seecr,项目名称:meresco-lucene,代码行数:8,代码来源:suggestionindexcomponenttest.py


示例4: testClearCache

 def testClearCache(self):
     def someMessage(*args, **kwargs):
         raise StopIteration('result')
         yield
     self.observer.methods['someMessage'] = someMessage
     retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
     self.assertEquals(['someMessage'], self.observer.calledMethodNames())
     self.cache.clear()
     retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
     self.assertEquals(['someMessage', 'someMessage'], self.observer.calledMethodNames())
开发者ID:seecr,项目名称:meresco-components,代码行数:10,代码来源:timedmessagecachetest.py


示例5: testPutNGetLIFO

    def testPutNGetLIFO(self):
        sp = SocketPool(reactor=CallTrace())
        retval(sp.putSocketInPool(host='x', port=1, sock='A'))
        retval(sp.putSocketInPool(host='x', port=1, sock='B'))
        retval(sp.putSocketInPool(host='x', port=1, sock='C'))

        self.assertEquals('C', retval(sp.getPooledSocket(host='x', port=1)))
        self.assertEquals('B', retval(sp.getPooledSocket(host='x', port=1)))
        self.assertEquals('A', retval(sp.getPooledSocket(host='x', port=1)))
        self.assertEquals(None, retval(sp.getPooledSocket(host='x', port=1)))
开发者ID:seecr,项目名称:weightless-core,代码行数:10,代码来源:socketpooltest.py


示例6: testPutNGet1Put1StillLIFO

    def testPutNGet1Put1StillLIFO(self):
        sp = SocketPool(reactor=CallTrace())
        retval(sp.putSocketInPool(host='example.org', port=80, sock='A'))
        retval(sp.putSocketInPool(host='example.org', port=80, sock='B'))

        self.assertEquals('B', retval(sp.getPooledSocket(host='example.org', port=80)))

        retval(sp.putSocketInPool(host='example.org', port=80, sock='C'))

        self.assertEquals('C', retval(sp.getPooledSocket(host='example.org', port=80)))
        self.assertEquals('A', retval(sp.getPooledSocket(host='example.org', port=80)))
        self.assertEquals(None, retval(sp.getPooledSocket(host='example.org', port=80)))
开发者ID:seecr,项目名称:weightless-core,代码行数:12,代码来源:socketpooltest.py


示例7: testDrilldownQuery

    def testDrilldownQuery(self):
        result = retval(self.dbdq.executeQuery(extraArguments={'x-drilldown-query': ['a = b']}))
        self.assertEquals('result', result)
        self.assertEquals(['executeQuery'], self.observer.calledMethodNames())
        executeQueryMethod = self.observer.calledMethods[0]
        self.assertEquals([('a', ['b'])], executeQueryMethod.kwargs['drilldownQueries'])

        self.observer.calledMethods.reset()

        result = retval(self.dbdq.executeQuery(extraArguments={'x-drilldown-query': ['a exact b']}))
        self.assertEquals('result', result)
        self.assertEquals(['executeQuery'], self.observer.calledMethodNames())
        executeQueryMethod = self.observer.calledMethods[0]
        self.assertEquals([('a', ['b'])], executeQueryMethod.kwargs['drilldownQueries'])
开发者ID:seecr,项目名称:meresco-components,代码行数:14,代码来源:drilldownqueriestest.py


示例8: testTimeoutExceptionWithoutCachedResult

    def testTimeoutExceptionWithoutCachedResult(self):
        self.init(cacheTimeout=0.1, returnCachedValueInCaseOfException=True, backoffTimeout=0.1)
        def someMessageTimeout(*args, **kwargs):
            raise TimeoutException()
            yield
        self.observer.methods['someMessage'] = someMessageTimeout
        self.assertRaises(BackoffException, lambda: retval(self.dna.any.someMessage('arg', kwarg='kwarg')))
        self.assertEquals(['someMessage'], self.observer.calledMethodNames())
        self.assertRaises(BackoffException, lambda: retval(self.dna.any.someMessage('arg', kwarg='kwarg')))
        self.assertEquals(['someMessage'], self.observer.calledMethodNames())
        sleep(0.11)

        self.assertRaises(BackoffException, lambda: retval(self.dna.any.someMessage('arg', kwarg='kwarg')))
        self.assertEquals(['someMessage', 'someMessage'], self.observer.calledMethodNames())
开发者ID:seecr,项目名称:meresco-components,代码行数:14,代码来源:timedmessagecachetest.py


示例9: testPutEmptyPut

    def testPutEmptyPut(self):
        sp = SocketPool(reactor=CallTrace())
        retval(sp.putSocketInPool(host='10.0.0.1', port=60000, sock=0))
        retval(sp.putSocketInPool(host='10.0.0.1', port=60000, sock=1))

        for i in reversed(range(2)):
            self.assertEquals(i, retval(sp.getPooledSocket(host='10.0.0.1', port=60000)))
        self.assertEquals(None, retval(sp.getPooledSocket(host='10.0.0.1', port=60000)))

        retval(sp.putSocketInPool(host='10.0.0.1', port=60000, sock=2))
        self.assertEquals(2, retval(sp.getPooledSocket(host='10.0.0.1', port=60000)))
开发者ID:seecr,项目名称:weightless-core,代码行数:11,代码来源:socketpooltest.py


示例10: testSortWithJoinField

    def testSortWithJoinField(self):
        joinSortCollector = JoinSortCollector(KEY_PREFIX + 'A', KEY_PREFIX+'B')
        self.luceneB.search(query=MatchAllDocsQuery(), collector=joinSortCollector)

        sortField = JoinSortField('T', self.registry.sortFieldType('T'), False, joinSortCollector)
        sortField.setMissingValue(self.registry.defaultMissingValueForSort('T', False))

        result = retval(self.luceneA.executeQuery(MatchAllDocsQuery(), sortKeys=[sortField]))
        self.assertEqual(['A-M', 'A-MU', 'A-MQ', 'A-MQU', 'A', 'A-U', 'A-Q', 'A-QU'], [hit.id for hit in result.hits])

        sortField = JoinSortField('T', self.registry.sortFieldType('T'), True, joinSortCollector)
        sortField.setMissingValue(self.registry.defaultMissingValueForSort('T', True))

        result = retval(self.luceneA.executeQuery(MatchAllDocsQuery(), sortKeys=[sortField]))
        self.assertEqual(['A-MQU', 'A-MQ', 'A-MU', 'A-M', 'A', 'A-U', 'A-Q', 'A-QU'], [hit.id for hit in result.hits])
开发者ID:FashtimeDotCom,项目名称:meresco-lucene,代码行数:15,代码来源:multiluceneoldtest.py


示例11: XXX_NOT_YET_IMPLEMENTED_testRankQueryInSingleCoreQuery

 def XXX_NOT_YET_IMPLEMENTED_testRankQueryInSingleCoreQuery(self):
     q = ComposedQuery('coreA', query=MatchAllDocsQuery())
     q.addMatch(dict(core='coreA', uniqueKey=KEY_PREFIX+'A'), dict(core='coreB', key=KEY_PREFIX+'B'))
     q.setRankQuery(core='coreA', query=luceneQueryFromCql('Q=true'))
     result = retval(self.dna.any.executeComposedQuery(q))
     self.assertEquals(8, result.total)
     self.assertEquals([u'A-Q', u'A-QU', u'A-MQ', u'A-MQU', u'A', u'A-U', u'A-M', u'A-MU'], [hit.id for hit in result.hits])
开发者ID:FashtimeDotCom,项目名称:meresco-lucene,代码行数:7,代码来源:multiluceneoldtest.py


示例12: testTimeoutExceptionIsRaiseIfNoBackoffTimeoutSet

 def testTimeoutExceptionIsRaiseIfNoBackoffTimeoutSet(self):
     self.init(cacheTimeout=0.1)
     def someMessageTimeout(*args, **kwargs):
         raise TimeoutException()
         yield
     self.observer.methods['someMessage'] = someMessageTimeout
     self.assertRaises(TimeoutException, lambda: retval(self.dna.any.someMessage('arg', kwarg='kwarg')))
开发者ID:seecr,项目名称:meresco-components,代码行数:7,代码来源:timedmessagecachetest.py


示例13: testInfoOnQuery

    def testInfoOnQuery(self):
        self.response = JsonDict({"total": 887, "queryTime": 6, "hits": [{"id": "record:1", "score": 0.1234}]}).dumps()

        q = ComposedQuery("coreA")
        q.addFilterQuery("coreB", query="N=true")
        q.addMatch(dict(core="coreA", uniqueKey="A"), dict(core="coreB", key="B"))
        result = retval(self._multiLucene.executeComposedQuery(q))
        self.assertEquals(
            {
                "query": {
                    "cores": ["coreB", "coreA"],
                    "drilldownQueries": {},
                    "facets": {},
                    "filterQueries": {"coreB": ["N=true"]},
                    "matches": {"coreA->coreB": [{"core": "coreA", "uniqueKey": "A"}, {"core": "coreB", "key": "B"}]},
                    "otherCoreFacetFilters": {},
                    "queries": {},
                    "rankQueries": {},
                    "resultsFrom": "coreA",
                    "sortKeys": [],
                    "unites": [],
                },
                "type": "ComposedQuery",
            },
            result.info,
        )
开发者ID:seecr,项目名称:meresco-lucene,代码行数:26,代码来源:multilucenetest.py


示例14: testNoDrilldownQuery

 def testNoDrilldownQuery(self):
     result = retval(self.dbdq.executeQuery(extraArguments={}, query='*'))
     self.assertEquals('result', result)
     self.assertEquals(['executeQuery'], self.observer.calledMethodNames())
     executeQueryMethod = self.observer.calledMethods[0]
     self.assertEquals([], executeQueryMethod.kwargs['drilldownQueries'])
     self.assertEquals("*", executeQueryMethod.kwargs['query'])
开发者ID:seecr,项目名称:meresco-components,代码行数:7,代码来源:drilldownqueriestest.py


示例15: testTotalShingleRecords

 def testTotalShingleRecords(self):
     self.response = "10"
     total = retval(self.sic.totalShingleRecords())
     self.assertEqual(10, total)
     self.assertEqual(0, len(self.post))
     self.assertEqual(1, len(self.get))
     self.assertEqual('/totalRecords', self.get[0])
开发者ID:seecr,项目名称:meresco-lucene,代码行数:7,代码来源:suggestionindexcomponenttest.py


示例16: testTotalSuggestions

 def testTotalSuggestions(self):
     self.response = "10"
     total = retval(self.sic.totalSuggestions())
     self.assertEqual(10, total)
     self.assertEqual(0, len(self.post))
     self.assertEqual(1, len(self.get))
     self.assertEqual('/totalSuggestions', self.get[0])
开发者ID:seecr,项目名称:meresco-lucene,代码行数:7,代码来源:suggestionindexcomponenttest.py


示例17: testNoQueryInCaseOfGeoLatLong

    def testNoQueryInCaseOfGeoLatLong(self):
        queries = []
        def queryErfGeoApi(query, expectedType=None):
            queries.append(dict(query=query, expectedType=expectedType))
            raise StopIteration(QUERY_RESULTS)
            yield

        def toAnnotation(pit, targetUri, query, geoCoordinates=None):
            return PitToAnnotation().toAnnotation(pit=pit, targetUri=targetUri, query=query, geoCoordinates=geoCoordinates)

        observer = CallTrace('observer', methods={'queryErfGeoApi': queryErfGeoApi, 'toAnnotation': toAnnotation})
        top = be(
            (Observable(),
                (ErfGeoEnrichmentFromSummary(),
                    (observer,)
                )
            )
        )

        summary = makeSummary([], geoLatLong=('51.8', '5.0'))
        result = retval(top.any.annotationFromSummary(summary))
        self.assertEquals([], queries)
        annotationUri, annotation = result
        self.assertEquals(ERFGEO_ENRICHMENT_PROFILE.uriFor('uri:target'), annotationUri)
        self.assertEquals('51.8', xpathFirst(annotation, '/rdf:RDF/oa:Annotation/oa:hasBody/rdf:Description/geo:lat/text()'))
开发者ID:seecr,项目名称:dc-erfgeo-enrich,代码行数:25,代码来源:erfgeoenrichmentfromsummarytest.py


示例18: testCacheAny

 def testCacheAny(self):
     def someMessage(*args, **kwargs):
         raise StopIteration('result')
         yield
     self.observer.methods['someMessage'] = someMessage
     result = retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
     self.assertEquals('result', result)
     result = retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
     self.assertEquals('result', result)
     self.assertEquals(['someMessage'], self.observer.calledMethodNames())
     sleep(0.11)
     result = retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
     self.assertEquals('result', result)
     self.assertEquals(['someMessage', 'someMessage'], self.observer.calledMethodNames())
     result = retval(self.dna.any.someMessage('arg', kwarg='otherkwarg'))
     self.assertEquals(['someMessage', 'someMessage', 'someMessage'], self.observer.calledMethodNames())
开发者ID:seecr,项目名称:meresco-components,代码行数:16,代码来源:timedmessagecachetest.py


示例19: testTimeoutExceptionNotHandledSpecially

    def testTimeoutExceptionNotHandledSpecially(self):
        self.init(cacheTimeout=0.1, returnCachedValueInCaseOfException=True)
        def someMessageResult(*args, **kwargs):
            raise StopIteration('result')
            yield
        def someMessageTimeout(*args, **kwargs):
            raise TimeoutException()
            yield
        self.observer.methods['someMessage'] = someMessageResult
        result = retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
        self.assertEquals(['someMessage'], self.observer.calledMethodNames())
        sleep(0.11)

        self.observer.methods['someMessage'] = someMessageTimeout
        result = retval(self.dna.any.someMessage('arg', kwarg='kwarg'))
        self.assertEquals('result', result)
        self.assertEquals(['someMessage', 'someMessage'], self.observer.calledMethodNames())
开发者ID:seecr,项目名称:meresco-components,代码行数:17,代码来源:timedmessagecachetest.py


示例20: t

 def t():
     sok = MockSok('s')
     current_exc = []
     def shutdown(*a, **kw):
         e = exceptions.pop(0)
         current_exc.append(e)
         raise e
     sok.log.methods['shutdown'] = shutdown
     sp = EmptySocketPool()
     try:
         retval(sp.putSocketInPool(host='secure.example.org', port=9999, sock=sok))
     except type(current_exc[0]):
         pass
     else:
         self.fail()
     self.assertEquals(['shutdown'], sok.log.calledMethodNames())
     self.assertEquals(((SHUT_RDWR,), {}), (sok.log.calledMethods[0].args, sok.log.calledMethods[0].kwargs))
开发者ID:seecr,项目名称:weightless-core,代码行数:17,代码来源:socketpooltest.py



注:本文中的weightless.core.retval函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python http.HttpServer类代码示例发布时间:2022-05-26
下一篇:
Python core.consume函数代码示例发布时间:2022-05-26
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap