confluent_2
2015-09-18 16:19:17 11 举报
登录查看完整内容
Confluent_2是一个开源的分布式流处理平台，它提供了一种高效、可扩展的方式来处理和分析实时数据。该平台基于Apache Kafka和Apache Flink构建，支持多种数据源和数据格式，包括JSON、Avro、Parquet等。 Confluent_2具有强大的容错能力和高吞吐量，可以处理数百万条消息/秒。它还提供了丰富的API和工具，使开发人员能够轻松地构建复杂的数据处理管道。此外，Confluent_2还支持与许多流行的大数据技术集成，如Hadoop、Spark等。 总之，Confluent_2是一个功能强大、易于使用的分布式流处理平台，适用于各种实时数据处理场景。
作者其他创作
大纲/内容
process_request()
ipmi.py
ClientConsoleConsoleSession
create object
start
event.wait()
handle_node_request()(core.py)
delete()
users
IpmiConsole runs in the eventlet started from sockapi or httpapi
retrieve()
result:resultdata = queue.LightQueue()
create()
operation
event.send()
class IpmiConsole
eventlet
nodes
nodegroups
noderange
_ipmiwaiters(eventlet.Event)
class ipmihandler
pathexample:/nodes/n2
perform_requests()
pluginmapgetattr(operation)
pyghmi.console.Session.wait_rsp()
ConsoleClient
update()
handle_path()(core.py)
_ipmi_evtloop
start from socketapi eventlet
greenpool.spawn()
function
0 条评论
回复 删除
下一页
