py-amqp の API リファレンス
py-amqp (celery/py-amqp) の公開 API 79 件 —— クラス 49、関数 10、メソッド 20。実際のソースを静的解析して抽出した正確なシグネチャを掲載しています。
リポジトリ: celery/py-amqp
| 種別 | 件数 |
|---|---|
| クラス | 49 |
| 関数 | 10 |
| メソッド | 20 |
API 一覧
class
amqp.abstract_channel.AbstractChannelSuperclass for Connection and Channel.
method
amqp.abstract_channel.AbstractChannel.close()Close this Channel or Connection.
class
amqp.basic_message.MessageA Message for use with the Channel.basic_* methods.
class
amqp.channel.ChannelAMQP Channel.
method
amqp.channel.Channel.basic_ack(delivery_tag, multiple=False, argsig='Lb')Acknowledge one or more messages.
method
amqp.channel.Channel.basic_cancel(consumer_tag, nowait=False, argsig='sb')End a queue consumer.
method
amqp.channel.Channel.basic_get(queue='', no_ack=False, argsig='Bsb')Direct access to a queue.
method
amqp.channel.Channel.basic_qos(prefetch_size, prefetch_count, a_global, argsig='lBb')Specify quality of service.
method
amqp.channel.Channel.basic_recover(requeue=False)Redeliver unacknowledged messages.
method
amqp.channel.Channel.basic_reject(delivery_tag, requeue, argsig='Lb')Reject an incoming message.
method
amqp.channel.Channel.close(reply_code=0, reply_text='', method_sig=(0, 0), argsig='BsBB')Request a channel close.
method
amqp.channel.Channel.collect()Tear down this object.
method
amqp.channel.Channel.exchange_delete(exchange, if_unused=False, nowait=False, argsig='Bsbb')Delete an exchange.
method
amqp.channel.Channel.flow(active)Enable/disable flow from peer.
method
amqp.channel.Channel.open()Open a channel for use.
method
amqp.channel.Channel.queue_delete(queue='', if_unused=False, if_empty=False, nowait=False, argsig='Bsbbb')Delete a queue.
method
amqp.channel.Channel.queue_purge(queue='', nowait=False, argsig='Bsb')Purge a queue.
method
amqp.channel.Channel.tx_commit()Commit the current transaction.
method
amqp.channel.Channel.tx_rollback()Abandon the current transaction.
method
amqp.channel.Channel.tx_select()Select standard transaction mode.
class
amqp.connection.ConnectionAMQP Connection.
method
amqp.connection.Connection.channel(channel_id=None, callback=None)Create new channel.
method
amqp.connection.Connection.close(reply_code=0, reply_text='', method_sig=(0, 0), argsig='BsBB')Request a connection close.
method
amqp.connection.Connection.heartbeat_tick(rate=2)Send heartbeat packets if necessary.
class
amqp.exceptions.AMQPDeprecationWarningWarning for deprecated things.
class
amqp.exceptions.AMQPErrorBase class for all AMQP exceptions.
class
amqp.exceptions.AMQPNotImplementedErrorAMQP Not Implemented Error.
class
amqp.exceptions.AccessRefusedAMQP Access Refused Error.
class
amqp.exceptions.BlockedAMQP Connection Blocked Predicate.
class
amqp.exceptions.ChannelErrorAMQP Channel Error.
class
amqp.exceptions.ChannelNotOpenAMQP Channel Not Open Error.
class
amqp.exceptions.ConnectionErrorAMQP Connection Error.
class
amqp.exceptions.ConnectionForcedAMQP Connection Forced Error.
class
amqp.exceptions.ConsumerCancelledAMQP Consumer Cancelled Predicate.
class
amqp.exceptions.ContentTooLargeAMQP Content Too Large Error.
class
amqp.exceptions.FrameErrorAMQP Frame Error.
class
amqp.exceptions.FrameSyntaxErrorAMQP Frame Syntax Error.
class
amqp.exceptions.InternalErrorAMQP Internal Error.
class
amqp.exceptions.InvalidCommandAMQP Invalid Command Error.
class
amqp.exceptions.InvalidPathAMQP Invalid Path Error.
class
amqp.exceptions.IrrecoverableChannelErrorException class for irrecoverable channel errors.
class
amqp.exceptions.IrrecoverableConnectionErrorException class for irrecoverable connection errors.
class
amqp.exceptions.MessageNackedMessage was nacked by broker.
class
amqp.exceptions.NoConsumersAMQP No Consumers Error.
class
amqp.exceptions.NotAllowedAMQP Not Allowed Error.
class
amqp.exceptions.NotFoundAMQP Not Found Error.
class
amqp.exceptions.PreconditionFailedAMQP Precondition Failed Error.
class
amqp.exceptions.RecoverableChannelErrorException class for recoverable channel errors.
class
amqp.exceptions.RecoverableConnectionErrorException class for recoverable connection errors.
class
amqp.exceptions.ResourceErrorAMQP Resource Error.
class
amqp.exceptions.ResourceLockedAMQP Resource Locked Error.
class
amqp.exceptions.UnexpectedFrameAMQP Unexpected Frame.
class
amqp.sasl.AMQPLAINAMQPLAIN SASL authentication mechanism.
class
amqp.sasl.EXTERNALEXTERNAL SASL mechanism.
class
amqp.sasl.FakeGSSAPIA no-op SASL mechanism for when gssapi isn't available.
class
amqp.sasl.GSSAPIGSSAPI SASL authentication mechanism.
class
amqp.sasl.PLAINPLAIN SASL authentication mechanism.
class
amqp.sasl.RAWA generic custom SASL mechanism.
class
amqp.sasl.SASLThe base class for all amqp SASL authentication mechanisms.
class
amqp.serialization.GenericContentAbstract base class for AMQP content.
func
amqp.serialization.decode_properties_basic(buf, offset)Decode basic properties.
func
amqp.serialization.dumps(format, values)Serialize AMQP arguments.
func
amqp.serialization.loads(format, buf, offset)Deserialize amqp format.
class
amqp.spec.BasicAMQ Basic class.
class
amqp.spec.ChannelAMQ Channel class.
class
amqp.spec.ConfirmAMQ Confirm class.
class
amqp.spec.ConnectionAMQ Connection class.
class
amqp.spec.ExchangeAMQ Exchange class.
class
amqp.spec.QueueAMQ Queue class.
class
amqp.spec.TxAMQ Tx class.
func
amqp.spec.method(method_sig, args=None, content=False)Create amqp method specification tuple.
class
amqp.transport.SSLTransportTransport that works over SSL.
class
amqp.transport.TCPTransportTransport that deals directly with TCP socket.
func
amqp.transport.Transport(host, connect_timeout=None, ssl=False, **kwargs)Create transport.
func
amqp.utils.bytes_to_str(s)Convert bytes to str.
func
amqp.utils.coro(gen)Decorator to mark generator as a co-routine.
func
amqp.utils.get_logger(logger)Get logger by name.
func
amqp.utils.set_cloexec(fd, cloexec)Set flag to close fd after exec.
func
amqp.utils.str_to_bytes(s)Convert str to bytes.
この情報について
掲載しているシグネチャは celery/py-amqp の公開ソースコードを
Python の ast モジュールで静的解析し、引数名・デフォルト値・
型注釈・戻り値型をそのまま抽出したものです。実装コードは保存していません。
詳しくは仕組みの解説をご覧ください。