brk-code

kombu の API リファレンス

kombu (celery/kombu) の公開 API 343 件 —— クラス 164、関数 69、メソッド 110。実際のソースを静的解析して抽出した正確なシグネチャを掲載しています。

リポジトリ: celery/kombu

種別件数
クラス164
関数69
メソッド110

API 一覧

classkombu.abstract.MaybeChannelBound
Mixin for classes that can be bound to an AMQP channel.
methodkombu.abstract.MaybeChannelBound.bind(channel:Channel | Connection) -> _MaybeChannelBoundType
Create copy of the instance that is bound to a channel.
methodkombu.abstract.MaybeChannelBound.channel() -> Channel
Current channel if the object is bound.
methodkombu.abstract.MaybeChannelBound.is_bound() -> bool
Flag set if the channel is bound.
methodkombu.abstract.MaybeChannelBound.maybe_bind(channel:Channel | Connection) -> _MaybeChannelBoundType
Bind instance to channel if not already bound.
methodkombu.abstract.MaybeChannelBound.revive(channel:Channel) -> None
Revive channel after the connection has been re-established.
methodkombu.abstract.MaybeChannelBound.when_bound() -> None
Callback called when the class is bound.
classkombu.abstract.Object
Common base class.
funckombu.asynchronous.aws.connect_sqs(aws_access_key_id:str | None=None, aws_secret_access_key:str | None=None, **kwargs:Any) -> AsyncSQSConnection
Return async connection to Amazon SQS.
classkombu.asynchronous.aws.connection.AsyncAWSQueryConnection
Async AWS Query Connection.
classkombu.asynchronous.aws.connection.AsyncConnection
Async AWS Connection.
classkombu.asynchronous.aws.connection.AsyncHTTPResponse
Async HTTP Response.
classkombu.asynchronous.aws.connection.AsyncHTTPSConnection
Async HTTP Connection.
classkombu.asynchronous.aws.sqs.connection.AsyncSQSConnection
Async SQS Connection.
classkombu.asynchronous.aws.sqs.message.AsyncMessage
Serialized message.
methodkombu.asynchronous.aws.sqs.message.AsyncMessage.encode(value)
Encode/decode the value using Base64 encoding.
classkombu.asynchronous.aws.sqs.message.AsyncRawMessage
Raw Message.
classkombu.asynchronous.aws.sqs.message.BaseAsyncMessage
Base class for messages received on async client.
classkombu.asynchronous.aws.sqs.queue.AsyncQueue
Async SQS Queue.
funckombu.asynchronous.debug.repr_flag(flag)
Return description of event loop flag.
funckombu.asynchronous.debug.repr_readers(h)
Return description of pending readers.
funckombu.asynchronous.debug.repr_writers(h)
Return description of pending writers.
funckombu.asynchronous.http.Client(hub:Hub | None=None, **kwargs:int) -> CurlClient
Create new HTTP client.
classkombu.asynchronous.http.base.Headers
Represents a mapping of HTTP headers.
classkombu.asynchronous.http.base.Request
A HTTP Request.
classkombu.asynchronous.http.base.Response
HTTP Response.
methodkombu.asynchronous.http.base.Response.body()
The full contents of the response body.
classkombu.asynchronous.http.curl.CurlClient
Curl HTTP Client.
funckombu.asynchronous.http.get_client(hub:Hub | None=None, **kwargs:int) -> CurlClient
Get or create HTTP client bound to the current event loop.
classkombu.asynchronous.hub.Hub
Event loop object.
classkombu.asynchronous.hub.Stop
Stops the event loop.
funckombu.asynchronous.hub.get_event_loop() -> Hub | None
Get current event loop object.
funckombu.asynchronous.hub.set_event_loop(loop:Hub | None) -> Hub | None
Set the current event loop object.
classkombu.asynchronous.semaphore.DummyLock
Pretending to be a lock.
classkombu.asynchronous.semaphore.LaxBoundedSemaphore
Asynchronous Bounded Semaphore.
methodkombu.asynchronous.semaphore.LaxBoundedSemaphore.acquire(callback:Callable[P, None], *partial_args:P.args, **partial_kwargs:P.kwargs) -> bool
Acquire semaphore.
methodkombu.asynchronous.semaphore.LaxBoundedSemaphore.grow(n:int=1) -> None
Change the size of the semaphore to accept more users.
methodkombu.asynchronous.semaphore.LaxBoundedSemaphore.release() -> None
Release semaphore.
methodkombu.asynchronous.semaphore.LaxBoundedSemaphore.shrink(n:int=1) -> None
Change the size of the semaphore to accept less users.
classkombu.asynchronous.timer.Entry
Schedule Entry.
classkombu.asynchronous.timer.Timer
Async timer implementation.
methodkombu.asynchronous.timer.Timer.queue(_pop=heapq.heappop)
Snapshot of underlying datastructure.
funckombu.asynchronous.timer.to_timestamp(d, default_timezone=ZoneInfo('UTC'), time=monotonic)
Convert datetime to timestamp.
classkombu.clocks.LamportClock
Lamport's logical clock.
methodkombu.clocks.LamportClock.sort_heap(h:list[tuple[int, str]]) -> tuple[int, str]
Sort heap of events.
classkombu.clocks.timetuple
Tuple of event clock information.
classkombu.common.Broadcast
Broadcast queue.
classkombu.common.QoS
Thread safe increment/decrement of a channels prefetch_count.
methodkombu.common.QoS.set(pcount)
Set channel prefetch_count setting.
methodkombu.common.QoS.update()
Update prefetch count with current value.
funckombu.common.ignore_errors(conn, fun=None, *args, **kwargs)
Ignore connection and channel errors.
funckombu.common.itermessages(conn, channel, queue, limit=1, timeout=None, callbacks=None, **kwargs)
Iterator over messages.
funckombu.common.maybe_declare(entity, channel=None, retry=False, **retry_policy)
Declare entity (cached).
funckombu.common.send_reply(exchange, req, msg, producer=None, retry=False, retry_policy=None, **props)
Send reply for request.
classkombu.compat.Consumer
Carrot compatible consumer.
classkombu.compat.Publisher
Carrot compatible producer.
funckombu.compression.compress(body, content_type)
Compress text.
funckombu.compression.decompress(body, content_type)
Decompress compressed text.
funckombu.compression.get_decoder(t)
Get decoder by alias name.
funckombu.compression.get_encoder(t)
Get encoder by alias name.
funckombu.compression.register(encoder, decoder, content_type, aliases=None)
Register new compression method.
classkombu.connection.ChannelPool
Pool of channels.
classkombu.connection.Connection
A connection to the broker.
methodkombu.connection.Connection.ChannelPool(limit=None, **kwargs)
Pool of channels.
methodkombu.connection.Connection.Pool(limit=None, **kwargs)
Pool of connections.
methodkombu.connection.Connection.channel()
Create and return a new channel.
methodkombu.connection.Connection.connection()
The underlying connection object.
methodkombu.connection.Connection.default_channel() -> Channel
Default channel.
methodkombu.connection.Connection.get_transport_cls()
Get the currently used transport class.
methodkombu.connection.Connection.heartbeat_check(rate=2)
Check heartbeats.
methodkombu.connection.Connection.info()
Get connection info.
methodkombu.connection.Connection.manager()
AMQP Management API.
methodkombu.connection.Connection.recoverable_channel_errors()
Recoverable channel errors.
methodkombu.connection.Connection.recoverable_connection_errors()
Recoverable connection errors.
methodkombu.connection.Connection.release()
Close the connection (if open).
classkombu.connection.ConnectionPool
Pool of connections.
classkombu.connection.PooledConnection
Wraps :class:`kombu.Connection`.
funckombu.connection.maybe_channel(channel:Channel | Connection) -> Channel
Get channel from object.
classkombu.entity.Exchange
An Exchange declaration.
methodkombu.entity.Exchange.Message(body, delivery_mode=None, properties=None, **kwargs)
Create message instance to be sent with :meth:`publish`.
methodkombu.entity.Exchange.declare(nowait=False, passive=None, channel=None)
Declare the exchange.
methodkombu.entity.Exchange.publish(message, routing_key=None, mandatory=False, immediate=False, exchange=None)
Publish message.
classkombu.entity.Queue
A Queue declaration.
methodkombu.entity.Queue.cancel(consumer_tag)
Cancel a consumer by consumer tag.
methodkombu.entity.Queue.consume(consumer_tag='', callback=None, no_ack=None, nowait=False, on_cancel=None)
Start a queue consumer.
methodkombu.entity.Queue.delete(if_unused=False, if_empty=False, nowait=False)
Delete the queue.
methodkombu.entity.Queue.get(no_ack=None, accept=None)
Poll the server for a new message.
methodkombu.entity.Queue.purge(nowait=False)
Remove all ready messages from the queue.
methodkombu.entity.Queue.queue_declare(nowait=False, passive=False, channel=None)
Declare queue on the server.
classkombu.entity.binding
Represents a queue or exchange binding.
methodkombu.entity.binding.bind(entity, nowait=False, channel=None)
Bind entity to this binding.
methodkombu.entity.binding.declare(channel, nowait=False)
Declare destination exchange.
methodkombu.entity.binding.unbind(entity, nowait=False, channel=None)
Unbind entity from this binding.
funckombu.entity.maybe_delivery_mode(v, modes=None, default=PERSISTENT_DELIVERY_MODE)
Get delivery mode by name (or none if undefined).
classkombu.exceptions.ChannelLimitExceeded
Maximum number of simultaneous channels exceeded.
classkombu.exceptions.ConnectionLimitExceeded
Maximum number of simultaneous connections exceeded.
classkombu.exceptions.ContentDisallowed
Consumer does not allow this content-type.
classkombu.exceptions.DecodeError
Cannot decode object.
classkombu.exceptions.EncodeError
Cannot encode object.
classkombu.exceptions.HttpError
HTTP Client Error.
classkombu.exceptions.InconsistencyError
Data or environment has been found to be inconsistent.
classkombu.exceptions.KombuError
Common subclass for all Kombu exceptions.
classkombu.exceptions.LimitExceeded
Limit exceeded.
classkombu.exceptions.MessageStateError
The message has already been acknowledged.
classkombu.exceptions.NotBoundError
Trying to call channel dependent method on unbound entity.
classkombu.exceptions.OperationalError
Recoverable message transport connection error.
classkombu.exceptions.SerializationError
Failed to serialize/deserialize content.
classkombu.exceptions.SerializerNotInstalled
Support for the requested serialization type is not installed.
classkombu.exceptions.VersionMismatch
Library dependency version mismatch.
funckombu.exceptions.reraise(tp:type[BaseExceptionType], value:BaseExceptionType, tb:TracebackType | None=None) -> BaseExceptionType
Reraise exception.
classkombu.log.LogMixin
Mixin that adds severity methods to any class.
funckombu.log.get_logger(logger:str | Logger)
Get logger by name.
funckombu.log.get_loglevel(level)
Get loglevel by name.
funckombu.log.setup_logging(loglevel=None, logfile=None)
Setup logging.
classkombu.matcher.MatcherNotInstalled
Matcher not installed/found.
classkombu.matcher.MatcherRegistry
Pattern matching function registry.
methodkombu.matcher.MatcherRegistry.match(data:bytes, pattern:bytes, matcher:str | None=None, matcher_kwargs:dict[str, str] | None=None) -> bool
Call the matcher.
methodkombu.matcher.MatcherRegistry.register(name:str, matcher:MatcherFunction) -> None
Add matcher by name to the registry.
methodkombu.matcher.MatcherRegistry.unregister(name:str) -> None
Remove matcher by name from the registry.
funckombu.matcher.register_glob() -> None
Register glob into default registry.
funckombu.matcher.register_pcre() -> None
Register pcre into default registry.
classkombu.message.Message
Base class for received messages.
methodkombu.message.Message.decode()
Deserialize the message body.
methodkombu.message.Message.payload()
The decoded message body.
methodkombu.message.Message.reject(requeue=False)
Reject this message.
classkombu.messaging.Consumer
Message consumer.
methodkombu.messaging.Consumer.cancel()
End all active queue consumers.
methodkombu.messaging.Consumer.cancel_by_queue(queue)
Cancel consumer by queue name.
methodkombu.messaging.Consumer.consume(no_ack=None)
Start consuming messages.
methodkombu.messaging.Consumer.declare()
Declare queues, exchanges and bindings.
methodkombu.messaging.Consumer.flow(active)
Enable/disable flow from peer.
methodkombu.messaging.Consumer.purge()
Purge messages from all queues.
methodkombu.messaging.Consumer.qos(prefetch_size=0, prefetch_count=0, apply_global=False)
Specify quality of service.
methodkombu.messaging.Consumer.receive(body, message)
Method called when a message is received.
methodkombu.messaging.Consumer.recover(requeue=False)
Redeliver unacknowledged messages.
methodkombu.messaging.Consumer.revive(channel)
Revive consumer after connection loss.
classkombu.messaging.Producer
Message Producer.
methodkombu.messaging.Producer.declare()
Declare the exchange.
classkombu.mixins.ConsumerMixin
Convenience mixin for implementing consumer programs.
classkombu.mixins.ConsumerProducerMixin
Consumer and Producer mixin.
classkombu.module
Customized Python module.
classkombu.pidbox.Mailbox
Process Mailbox.
classkombu.pidbox.Node
Mailbox node.
classkombu.pools.Connections
Collection of connection pools.
classkombu.pools.PoolGroup
Collection of resource pools.
classkombu.pools.ProducerPool
Pool of :class:`kombu.Producer` instances.
classkombu.pools.Producers
Collection of producer pools.
funckombu.pools.get_limit()
Get current connection pool limit.
funckombu.pools.register_group(group)
Register group (can be used as decorator).
funckombu.pools.reset(*args, **kwargs)
Reset all pools by closing open resources.
funckombu.pools.set_limit(limit, force=False, reset_after=False, ignore_errors=False)
Set new connection pool limit.
classkombu.resource.Resource
Pool of resources.
methodkombu.resource.Resource.acquire(block=False, timeout=None)
Acquire resource.
methodkombu.resource.Resource.replace(resource)
Replace existing resource with a new instance.
classkombu.serialization.SerializerRegistry
The registry keeps track of serialization methods.
methodkombu.serialization.SerializerRegistry.dumps(data, serializer=None)
Encode data.
funckombu.serialization.disable_insecure_serializers(allowed=NOTSET)
Disable untrusted serializers.
funckombu.serialization.not_available(*args, **kwargs)
Raise SerializerNotInstalled.
funckombu.serialization.raw_encode(data)
Special case serializer.
funckombu.serialization.register_msgpack()
Register msgpack serializer.
funckombu.serialization.register_pickle()
Register pickle serializer.
classkombu.simple.SimpleBuffer
Simple API for ephemeral queues.
classkombu.simple.SimpleQueue
Simple API for persistent queues.
classkombu.transport.SLMQ.Channel
SLMQ Channel.
classkombu.transport.SLMQ.Transport
SLMQ Transport.
classkombu.transport.SQS.Channel
SQS Channel.
methodkombu.transport.SQS.Channel.fanout() -> SnsFanout
Provides SNS fanout functionality.
methodkombu.transport.SQS.Channel.get_message_attributes() -> dict[str, Any]
Get the message attributes to be fetched from SQS.
methodkombu.transport.SQS.Channel.is_sts_token_refresh_required(name:Any, client_map:dict[str, BaseClient], expire_time:datetime | None=None) -> bool
Checks if the STS token needs renewing.
methodkombu.transport.SQS.Channel.new_sqs_client(region, access_key_id, secret_access_key, session_token=None)
Create a new SQS client.
methodkombu.transport.SQS.Channel.remove_stale_sns_subscriptions(exchange_name:str) -> None
Removes any stale SNS topic subscriptions.
classkombu.transport.SQS.QoS
Quality of Service guarantees implementation for SQS.
methodkombu.transport.SQS.SNS.SNS.get_client(exchange_name:str | None=None)
Get or create a Boto SNS client.
methodkombu.transport.SQS.SNS.SNS.initialise_exchange(exchange_name:str) -> None
Initialise SNS topic for a fanout exchange.
methodkombu.transport.SQS.SNS.SNS.serialise_message_attributes(message_attributes:dict | None) -> dict
Serialises SQS message attributes into SNS format.
classkombu.transport.SQS.Transport
SQS Transport.
classkombu.transport.SQS.exceptions.AccessDeniedQueueException
Raised when access to the AWS queue is denied.
classkombu.transport.SQS.exceptions.DoesNotExistQueueException
The specified queue doesn't exist.
classkombu.transport.azureservicebus.Channel
Azure Service Bus channel.
methodkombu.transport.azureservicebus.Channel.entity_name(name:str, table:dict[int, int] | None=None) -> str
Format AMQP queue name into a valid ServiceBus queue name.
classkombu.transport.azureservicebus.SendReceive
Container for Sender and Receiver.
classkombu.transport.azureservicebus.Transport
Azure Service Bus transport.
classkombu.transport.azurestoragequeues.Channel
Azure Storage Queues channel.
classkombu.transport.azurestoragequeues.Transport
Azure Storage Queues transport.
classkombu.transport.base.Implements
Helper class used to define transport features.
classkombu.transport.base.Management
AMQP Management API (incomplete).
classkombu.transport.base.StdChannel
Standard channel base class.
classkombu.transport.base.Transport
Base class for transports.
methodkombu.transport.base.Transport.as_uri(uri:str, include_password=False, mask='**') -> str
Customise the display format of the URI.
classkombu.transport.confluentkafka.Channel
Kafka Channel.
classkombu.transport.confluentkafka.Message
Message object.
classkombu.transport.confluentkafka.NoBrokersAvailable
Kafka broker is not available exception.
classkombu.transport.confluentkafka.QoS
Quality of Service guarantees.
methodkombu.transport.confluentkafka.QoS.reject(delivery_tag, requeue=False)
Reject a message by delivery tag.
classkombu.transport.confluentkafka.Transport
Kafka Transport.
classkombu.transport.consul.Channel
Consul Channel class which talks to the Consul Key/Value store.
classkombu.transport.consul.LockError
An error occurred while trying to acquire the lock.
classkombu.transport.consul.Transport
Consul K/V storage Transport for Kombu.
classkombu.transport.etcd.Channel
Etcd Channel class which talks to the Etcd.
classkombu.transport.etcd.Transport
Etcd storage Transport for Kombu.
methodkombu.transport.etcd.Transport.verify_connection(connection)
Verify the connection works.
classkombu.transport.filesystem.Channel
Filesystem Channel.
classkombu.transport.filesystem.Transport
Filesystem Transport.
funckombu.transport.filesystem.lock(file, flags)
Create file lock.
funckombu.transport.filesystem.unlock(file)
Remove file lock.
classkombu.transport.gcpubsub.AtomicCounter
Threadsafe counter.
classkombu.transport.gcpubsub.Channel
GCP Pub/Sub channel.
methodkombu.transport.gcpubsub.Channel.basic_ack(delivery_tag, multiple=False)
Acknowledge one message.
methodkombu.transport.gcpubsub.Channel.close()
Close the channel.
methodkombu.transport.gcpubsub.Channel.entity_name(name:str, table=CHARS_REPLACE_TABLE) -> str
Format AMQP queue name into a valid Pub/Sub queue name.
classkombu.transport.gcpubsub.QueueDescriptor
Pub/Sub queue descriptor.
classkombu.transport.gcpubsub.Transport
GCP Pub/Sub transport.
classkombu.transport.gcpubsub.UnackedIds
Threadsafe list of ack_ids.
funckombu.transport.get_transport_cls(transport:str | None=None) -> type | None
Get transport class by name.
classkombu.transport.librabbitmq.Channel
AMQP Channel (librabbitmq).
classkombu.transport.librabbitmq.Connection
AMQP Connection (librabbitmq).
classkombu.transport.librabbitmq.Message
AMQP Message (librabbitmq).
classkombu.transport.librabbitmq.Transport
AMQP Transport (librabbitmq).
classkombu.transport.memory.Channel
In-memory Channel.
classkombu.transport.memory.Transport
In-memory Transport.
classkombu.transport.mongodb.BroadcastCursor
Cursor for broadcast queues.
classkombu.transport.mongodb.Channel
MongoDB Channel.
methodkombu.transport.mongodb.Channel.get_now()
Return current time in UTC.
classkombu.transport.mongodb.Transport
MongoDB Transport.
funckombu.transport.native_delayed_delivery.level_name(level:int, prefix:str | None=None) -> str
Generates the delayed queue/exchange name based on the level.
classkombu.transport.pyamqp.Channel
AMQP Channel.
classkombu.transport.pyamqp.Connection
AMQP Connection.
classkombu.transport.pyamqp.Message
AMQP Message.
classkombu.transport.pyamqp.SSLTransport
AMQP SSL Transport.
classkombu.transport.pyamqp.Transport
AMQP Transport.
methodkombu.transport.pyamqp.Transport.close_connection(connection)
Close the AMQP broker connection.
classkombu.transport.pyro.Channel
Pyro Channel.
classkombu.transport.pyro.KombuBroker
Kombu Broker used by the Pyro transport.
classkombu.transport.pyro.Transport
Pyro Transport.
classkombu.transport.qpid.AuthenticationFailure
Cannot authenticate with Qpid.
classkombu.transport.qpid.Channel
Supports broker configuration and messaging send and receive.
methodkombu.transport.qpid.Channel.basic_cancel(consumer_tag)
Cancel consumer by consumer tag.
methodkombu.transport.qpid.Channel.basic_get(queue, no_ack=False, **kwargs)
Non-blocking single message get and ACK from a queue by name.
methodkombu.transport.qpid.Channel.basic_reject(delivery_tag, requeue=False)
Reject a message by delivery_tag.
methodkombu.transport.qpid.Channel.exchange_declare(exchange='', type='direct', durable=False, **kwargs)
Create a new exchange.
methodkombu.transport.qpid.Channel.qos()
:class:`QoS` manager for this channel.
methodkombu.transport.qpid.Channel.queue_delete(queue, if_unused=False, if_empty=False, **kwargs)
Delete a queue by name.
methodkombu.transport.qpid.Channel.typeof(exchange, default='direct')
Get the exchange type.
classkombu.transport.qpid.Connection
Qpid Connection.
methodkombu.transport.qpid.Connection.close()
Close the connection.
methodkombu.transport.qpid.Connection.close_channel(channel)
Close a Channel.
classkombu.transport.qpid.QoS
A helper object for message prefetch and ACKing purposes.
methodkombu.transport.qpid.QoS.ack(delivery_tag)
Acknowledge a message by delivery_tag.
methodkombu.transport.qpid.QoS.get(delivery_tag)
Get an un-ACKed message by delivery_tag.
methodkombu.transport.qpid.QoS.reject(delivery_tag, requeue=False)
Reject a message by delivery_tag.
classkombu.transport.qpid.Transport
Kombu native transport for a Qpid broker.
methodkombu.transport.qpid.Transport.establish_connection()
Establish a Connection object.
classkombu.transport.redis.Channel
Redis Channel.
classkombu.transport.redis.GlobalKeyPrefixMixin
Mixin to provide common logic for global key prefixing.
classkombu.transport.redis.MultiChannelPoller
Async I/O poller for Redis transport.
funckombu.transport.redis.Mutex(client, name, expire)
Acquire redis lock in non blocking way.
classkombu.transport.redis.MutexHeld
Raised when another party holds the lock.
classkombu.transport.redis.PrefixedRedisPipeline
Custom Redis pipeline that takes global_keyprefix into consideration.
classkombu.transport.redis.QoS
Redis Ack Emulation.
classkombu.transport.redis.SentinelChannel
Channel with explicit Redis Sentinel knowledge.
classkombu.transport.redis.SentinelManagedSSLConnection
Connect to a Redis server using Sentinel + TLS.
classkombu.transport.redis.SentinelTransport
Redis Sentinel Transport.
classkombu.transport.redis.Transport
Redis Transport.
funckombu.transport.redis.get_redis_error_classes()
Return tuple of redis error classes.
funckombu.transport.resolve_transport(transport:str | None=None) -> type | None
Get transport by name.
classkombu.transport.sqlalchemy.Channel
The channel class.
classkombu.transport.sqlalchemy.Transport
The transport class.
classkombu.transport.sqlalchemy.models.Message
The message class.
classkombu.transport.sqlalchemy.models.Queue
The queue class.
funckombu.transport.supports_librabbitmq() -> bool | None
Return true if :pypi:`librabbitmq` can be used.
classkombu.transport.virtual.base.AbstractChannel
Abstract channel interface.
classkombu.transport.virtual.base.Base64
Base64 codec.
classkombu.transport.virtual.base.BrokerState
Broker state holds exchanges, queues and bindings.
classkombu.transport.virtual.base.Channel
Virtual channel.
methodkombu.transport.virtual.base.Channel.basic_ack(delivery_tag, multiple=False)
Acknowledge message.
methodkombu.transport.virtual.base.Channel.basic_cancel(consumer_tag)
Cancel consumer by consumer tag.
methodkombu.transport.virtual.base.Channel.basic_consume(queue, no_ack, callback, consumer_tag, **kwargs)
Consume from `queue`.
methodkombu.transport.virtual.base.Channel.basic_publish(message, exchange, routing_key, **kwargs)
Publish message.
methodkombu.transport.virtual.base.Channel.basic_recover(requeue=False)
Recover unacked messages.
methodkombu.transport.virtual.base.Channel.basic_reject(delivery_tag, requeue=False)
Reject message.
methodkombu.transport.virtual.base.Channel.close()
Close channel.
methodkombu.transport.virtual.base.Channel.flow(active=True)
Enable/disable message flow.
methodkombu.transport.virtual.base.Channel.qos()
:class:`QoS` manager for this channel.
methodkombu.transport.virtual.base.Channel.queue_declare(queue=None, passive=False, **kwargs)
Declare queue.
methodkombu.transport.virtual.base.Channel.queue_delete(queue, if_unused=False, if_empty=False, **kwargs)
Delete queue.
classkombu.transport.virtual.base.Management
Base class for the AMQP management API.
classkombu.transport.virtual.base.Message
Message object.
classkombu.transport.virtual.base.QoS
Quality of Service guarantees.
methodkombu.transport.virtual.base.QoS.append(message, delivery_tag)
Append message to transactional state.
methodkombu.transport.virtual.base.QoS.restore_unacked()
Restore all unacknowledged messages.
classkombu.transport.virtual.base.Transport
Virtual transport.
classkombu.transport.virtual.base.UndeliverableWarning
The message could not be delivered to a queue.
classkombu.transport.virtual.exchange.DirectExchange
Direct exchange.
classkombu.transport.virtual.exchange.ExchangeType
Base class for exchanges.
methodkombu.transport.virtual.exchange.ExchangeType.prepare_bind(queue, exchange, routing_key, arguments)
Prepare queue-binding.
classkombu.transport.virtual.exchange.FanoutExchange
Fanout exchange.
classkombu.transport.virtual.exchange.TopicExchange
Topic exchange.
classkombu.transport.zookeeper.Channel
Zookeeper Channel.
classkombu.transport.zookeeper.Transport
Zookeeper Transport.
funckombu.utils.amq_manager.get_manager(client, hostname=None, port=None, userid=None, password=None)
Get pyrabbit manager.
classkombu.utils.collections.EqualityDict
Dict using the eq operator for keying.
classkombu.utils.collections.HashedSeq
Hashed Sequence.
funckombu.utils.collections.eqhash(o)
Call ``obj.__eqhash__``.
funckombu.utils.compat.coro(gen)
Decorator to mark generator as co-routine.
funckombu.utils.compat.fileno(f)
Get fileno from file-like object.
funckombu.utils.compat.nested(*managers)
Nest context managers.
classkombu.utils.debug.Logwrapped
Wrap all object methods, to log on call.
funckombu.utils.debug.setup_logging(loglevel:int | None=logging.DEBUG, loggers:list[str] | None=None) -> None
Setup logging to stdout.
funckombu.utils.encoding.bytes_to_str(s)
Convert bytes to str.
funckombu.utils.encoding.default_encode(obj)
Encode using default encoding.
funckombu.utils.encoding.default_encoding(file=None)
Get default encoding.
funckombu.utils.encoding.ensure_bytes(s)
Ensure s is bytes, not str.
funckombu.utils.encoding.from_utf8(s, *args, **kwargs)
Get str from utf-8 encoding.
funckombu.utils.encoding.safe_repr(o, errors='replace')
Safe form of repr, void of Unicode errors.
funckombu.utils.encoding.safe_str(s, errors='replace')
Safe form of str(), void of unicode errors.
funckombu.utils.encoding.str_to_bytes(s)
Convert str to bytes.
funckombu.utils.eventio.poll(*args, **kwargs)
Create new poller instance.
funckombu.utils.functional.clear()
Clear the cache and reset cache statistics.
classkombu.utils.functional.lazy
Holds lazy evaluation.
funckombu.utils.imports.symbol_by_name(name, aliases=None, imp=None, package=None, sep='.', default=None, **kwargs)
Get symbol by qualified name.
classkombu.utils.json.JSONEncoder
Kombu custom json encoder.
funckombu.utils.json.loads(s, _loads=json.loads, decode_bytes=True, object_hook=object_hook)
Deserialize json from string.
funckombu.utils.json.object_hook(o:dict)
Hook function to perform custom deserialization.
classkombu.utils.limits.TokenBucket
Token Bucket Algorithm.
classkombu.utils.objects.cached_property
Implementation of Cached property.
classkombu.utils.scheduling.FairCycle
Cycle between resources.
methodkombu.utils.scheduling.FairCycle.close()
Close cycle.
methodkombu.utils.scheduling.FairCycle.get(callback, **kwargs)
Get from next resource.
funckombu.utils.scheduling.cycle_by_name(name)
Get cycle class by name.
classkombu.utils.scheduling.priority_cycle
Cycle that repeats items in order.
methodkombu.utils.scheduling.priority_cycle.rotate(last_used)
Unused in this implementation.
classkombu.utils.scheduling.round_robin_cycle
Iterator that cycles between items in round-robin.
methodkombu.utils.scheduling.round_robin_cycle.consume(n)
Consume n items.
methodkombu.utils.scheduling.round_robin_cycle.update(it)
Update items from iterable.
classkombu.utils.scheduling.sorted_cycle
Cycle in sorted order.
methodkombu.utils.scheduling.sorted_cycle.consume(n)
Consume n items.
funckombu.utils.text.fmatch_best(needle:str, haystack:Iterable[str], min_ratio:float=0.6) -> str | None
Fuzzy match - Find best match (scalar).
funckombu.utils.text.fmatch_iter(needle:str, haystack:Iterable[str], min_ratio:float=0.6) -> Iterator[tuple[float, str]]
Fuzzy match: iteratively.
funckombu.utils.text.version_string_as_tuple(s:str) -> version_info_t
Convert version string to version info tuple.
funckombu.utils.time.maybe_s_to_ms(v:int | float | None) -> int | None
Convert seconds to milliseconds, but return None for None.
funckombu.utils.url.parse_url(url)
Parse URL into mapping of components.
classkombu.utils.url.urlparts
Named tuple representing parts of the URL.
funckombu.utils.uuid.uuid(_uuid:Callable[[], UUID]=uuid4) -> str
Generate unique id in UUID4 format.

この情報について

掲載しているシグネチャは celery/kombu の公開ソースコードを Python の ast モジュールで静的解析し、引数名・デフォルト値・ 型注釈・戻り値型をそのまま抽出したものです。実装コードは保存していません。 詳しくは仕組みの解説をご覧ください。

収録ライブラリ一覧（全 805 件）へ戻る