You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by Pankaj Bhagra <pa...@gmail.com> on 2017/08/08 01:05:44 UTC
proton server (azure SB) limit the incoming_window=5000
I am trying to extract bulk messages from azure SB.
As per their documentation the azure SDK doesn't support bulk read message
and recommends using the native amqp for the Azure Service Bus. White
trying to negotiate a session with the azure SB, i noticed that independent
of what client is requesting, the SB dials down the incoming_window=5000.
This limits a max of 5000B send per bulk read, thus my consumer runs dry
till the RTT (which is large for inter cloud) to fetch a new packet.
Is this a restriction of the azure SB or am i not setting any/some of the
parameters correctly from the client side to achieve the negotiated window
size > 5000B.
I am using python proton MessagingHandler Class and clearly see that
on_message is called for few pkts composing of buffer size ~5000B and then
have to wait for the RTT delay to get the next batch.
Any suggestion to work around this problem and get larger bulked message ?
I can't reduce the RTT between the server and consumer. have some
workaround for parallel consumers but would like to solve the bulk problem
as that is most efficient way of achieving the high throughput.
class Recv(MessagingHandler):
def __init__(self):
super(Recv, self).__init__(prefetch=100, auto_accept=True,
auto_settle=True, peer_close_is_error=False)
def on_start(self, event):
conn = event.container.connect(connString)
event.container.create_receiver(conn, subscription)
def on_message(self, event):
print(event.message.body)
print datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S.%f')[:-3],
self.count, event.receiver.queued
[0xace380]: -> SASL
[0xace380]: <- SASL
[0xace380]:0 <- @sasl-mechanisms(64)
[sasl-server-mechanisms=@PN_SYMBOL[:MSSBCBS, :PLAIN, :ANONYMOUS, :EXTERNAL]]
[0xace380]:0 -> @sasl-init(65) [mechanism=:PLAIN,
initial-response=b"\x00iothubroutes_XXXXX\XXXXX="]
[0xace380]:0 <- @sasl-outcome(68) [code=0, additional-data=b"Welcome!"]
[0xace380]: -> AMQP
[0xace380]:0 -> @open(16)
[container-id="0ad171ca-cefa-4a27-a7dc-0520e5393fa5", hostname="
nebhubsb.servicebus.windows.net", channel-max=32767]
[0xace380]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647,
outgoing-window=2147483647]
[0xace380]:0 -> @attach(18)
[name="0ad171ca-cefa-4a27-a7dc-0520e5393fa5-kukatopic/Subscriptions/kukasub",
handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0,
source=@source(40) [address="kukatopic/Subscriptions/kukasub", durable=0,
timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0,
dynamic=false], initial-delivery-count=0, max-message-size=0]
[0xace380]:0 -> @flow(19) [incoming-window=2147483647, next-outgoing-id=0,
outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=100,
drain=false]
[0xace380]: <- AMQP
[0xace380]:0 <- @open(16)
[container-id="b970f07881334c658eb80ff336f2a683_G16", max-frame-size=65536,
channel-max=4999, idle-time-out=240000]
[0xace380]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
incoming-window=5000, outgoing-window=2147483647, handle-max=255]
[0xace380]:0 <- @attach(18)
[name="0ad171ca-cefa-4a27-a7dc-0520e5393fa5-kukatopic/Subscriptions/kukasub",
handle=0, role=false, rcv-settle-mode=1, source=@source(40)
[address="topic/Subscriptions/sub", durable=0, timeout=0, dynamic=false],
target=@target(41) [durable=0, timeout=0, dynamic=false],
initial-delivery-count=0, max-message-size=266240]
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Gordon Sim <gs...@redhat.com>.
On 08/08/17 02:05, Pankaj Bhagra wrote:
> I am trying to extract bulk messages from azure SB.
>
> As per their documentation the azure SDK doesn't support bulk read message
> and recommends using the native amqp for the Azure Service Bus. White
> trying to negotiate a session with the azure SB, i noticed that independent
> of what client is requesting, the SB dials down the incoming_window=5000.
> This limits a max of 5000B send per bulk read, thus my consumer runs dry
> till the RTT (which is large for inter cloud) to fetch a new packet.
>
> Is this a restriction of the azure SB or am i not setting any/some of the
> parameters correctly from the client side to achieve the negotiated window
> size > 5000B.
>
> I am using python proton MessagingHandler Class and clearly see that
> on_message is called for few pkts composing of buffer size ~5000B and then
> have to wait for the RTT delay to get the next batch.
>
> Any suggestion to work around this problem and get larger bulked message ?
> I can't reduce the RTT between the server and consumer. have some
> workaround for parallel consumers but would like to solve the bulk problem
> as that is most efficient way of achieving the high throughput.
The incoming window is set by each peer independently (i.e. it is not
negotiated) and only covers the incoming transfers. For a link receiving
from service bus, the incoming window set by service bus isn't relevant.
It is the clients incoming window that would affect transfers from
service-bus to client.
How large are the messages? From the protocol trace it looks like you
are issuing 100 link credits. If the messages were all 50 bytes, that
might explain the limited batches you are seeing? You could try
increasing that link credit window.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Gordon Sim <gs...@redhat.com>.
On 10/08/17 19:47, Pankaj Bhagra wrote:
> Gordon,
>
> what is the meaning of "more" flags. I assume this means that server
> doesn't have more data to flush ? correct ?
No, it means is there any more data to be transferred for that specific
delivery i.e. that specific message.
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1220)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=1, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1231)
>
>
> If so, it appears that SB only caches 16K of data and doesn't refill this
> cache unless there is a new fetch request (which is painfully take the
> RTT).
What is triggering the next batch isn't really a fetch, since there was
already existing credit.
I think I may have misunderstood what you wanted to do in the previous
mail btw. Did you want to disable sending the flow? If you you can set
prefetch to 0, but then you have to do a receiver.flow(10000) (or
similar) when you first create the receiver, to give it credit. That way
it will not send a flow again after receiving the first set of
transfers, and you can see what effect that has, if any.
> Does it make sense to keep sending a prefetch request every few msec to
> keep the server busy and pulling data from whatever its backend store ?
The flow is already being sent back as soon as it has processed the
messages you have. The client is single threaded so while it is
processing the incoming transfers it won't be sending anything out.
However from the timestamps that seems to take very few millisecs.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Pankaj Bhagra <pa...@gmail.com>.
Gordon,
what is the meaning of "more" flags. I assume this means that server
doesn't have more data to flush ? correct ?
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1220)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=1, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1231)
If so, it appears that SB only caches 16K of data and doesn't refill this
cache unless there is a new fetch request (which is painfully take the
RTT).
Does it make sense to keep sending a prefetch request every few msec to
keep the server busy and pulling data from whatever its backend store ?
later,
pankaj
On Thu, Aug 10, 2017 at 10:54 AM, Pankaj Bhagra <pa...@gmail.com> wrote:
> My interest piqued by your pointer of forcing negotiation for getting
> "settled" messages s.t. server can keep sending them without awaiting
> client to acknowledge them. So i tried your recommendation of setting the
> link option AtMostOnce. I went further and force the AtMostOnce to set the
> "settled" for both send and receive message. However i still see server
> doesn't release the next batch till it receive the acknowledgement from
> client. this is puzzling, any other suggestion ?
>
> I wanted to experiment by disabling the flowControl. i did that by setting
> "prefetch"="None" , but that didn't get going. what would be way to disable
> the flow control to try out ?
>
> [0x24b0cd0]:0 -> @open(16) [container-id="3feb8312-b228-4052-87ec-5ab12633be0c",
> hostname="nebhubsb.servicebus.windows.net", channel-max=32767]
>
> [0x24b0cd0]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=
> 2147483647 <(214)%20748-3647>, outgoing-window=2147483647
> <(214)%20748-3647>]
>
> [0x24b0cd0]:0 -> @attach(18) [name="3feb8312-b228-4052-
> 87ec-5ab12633be0c-kukatopic/Subscriptions/kukasub", handle=0, role=true, snd-settle-mode=1,
> rcv-settle-mode=1, source=@source(40) [address="kukatopic/Subscriptions/kukasub",
> durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0,
> timeout=0, dynamic=false], initial-delivery-count=0, max-message-size=0]
>
> [0x24b0cd0]:0 -> @flow(19) [incoming-window=2147483647 <(214)%20748-3647>,
> next-outgoing-id=0, outgoing-window=2147483647 <(214)%20748-3647>,
> handle=0, delivery-count=0, link-credit=100, drain=false]
>
> [0x24b0cd0]: <- AMQP
>
> [0x24b0cd0]:0 <- @open(16) [container-id="2fdaeda28fb7483a9922790398ad1f0a_G20",
> max-frame-size=65536, channel-max=4999, idle-time-out=240000]
>
> [0x24b0cd0]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
> incoming-window=5000, outgoing-window=2147483647, handle-max=255]
>
> [0x24b0cd0]:0 <- @attach(18) [name="3feb8312-b228-4052-
> 87ec-5ab12633be0c-kukatopic/Subscriptions/kukasub", handle=0, role=false,
> snd-settle-mode=1, source=@source(40) [address="kukatopic/Subscriptions/kukasub",
> durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0,
> timeout=0, dynamic=false], initial-delivery-count=0,
> max-message-size=266240]
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1220)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=1, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1231)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=2, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1219)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=3, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1219)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=4, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1219)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=5, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1270)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=6, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1218)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=7, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1229)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=8, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (826)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=9, delivery-tag=b"",
> message-format=0, settled=true, more=false, batchable=true] (1218)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=10,
> delivery-tag=b"", message-format=0, settled=true, more=false,
> batchable=true] (1220)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=11,
> delivery-tag=b"", message-format=0, settled=true, more=false,
> batchable=true] (1216)
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=12,
> delivery-tag=b"", message-format=0, settled=true, more=false,
> batchable=true] (1216)
>
> 2017-08-10 01:49:00.417 pkt_seq = 1 remaining_in_batch = 12, 879
>
> 2017-08-10 01:49:00.417 pkt_seq = 2 remaining_in_batch = 11, 890
>
> 2017-08-10 01:49:00.417 pkt_seq = 3 remaining_in_batch = 10, 878
>
> 2017-08-10 01:49:00.418 pkt_seq = 4 remaining_in_batch = 9, 878
>
> 2017-08-10 01:49:00.419 pkt_seq = 5 remaining_in_batch = 8, 878
>
> 2017-08-10 01:49:00.419 pkt_seq = 6 remaining_in_batch = 7, 929
>
> 2017-08-10 01:49:00.419 pkt_seq = 7 remaining_in_batch = 6, 877
>
> 2017-08-10 01:49:00.420 pkt_seq = 8 remaining_in_batch = 5, 888
>
> 2017-08-10 01:49:00.420 pkt_seq = 9 remaining_in_batch = 4, 500
>
> 2017-08-10 01:49:00.421 pkt_seq = 10 remaining_in_batch = 3, 877
>
> 2017-08-10 01:49:00.421 pkt_seq = 11 remaining_in_batch = 2, 879
>
> 2017-08-10 01:49:00.421 pkt_seq = 12 remaining_in_batch = 1, 875
>
> 2017-08-10 01:49:00.422 pkt_seq = 13 remaining_in_batch = 0, 875
>
> [0x24b0cd0]:0 -> @flow(19) [next-incoming-id=14, incoming-window=
> 2147483647 <(214)%20748-3647>, next-outgoing-id=0, outgoing-window=
> 2147483647 <(214)%20748-3647>, handle=0, delivery-count=13,
> link-credit=99, drain=false]
>
> [0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=13,
> delivery-tag=b"", message-format=0, settled=true, more=false,
> batchable=true] (1218)
>
>
> and cycle continues ..
>
>
>
>
> On Thu, Aug 10, 2017 at 3:01 AM, Gordon Sim <gs...@redhat.com> wrote:
>
>> On 10/08/17 00:13, Pankaj Bhagra wrote:
>>
>>> Gordon,
>>>
>>> Further digging on network level sniffing shows that the bulk msg_size is
>>> limited to = 16373 (16K). this observation is inline with previously
>>> reported issue
>>>
>>
>> What do you mean by msg_size here?
>>
>> http://grokbase.com/t/qpid/users/163z91rhdy/ssl-maximum-message-size
>>>
>>
>> Interesting that the limit is the same, not sure what to make of that,
>> perhaps its just a commonly used buffer size. The 'solution' in that issue
>> was to break up large messages into multiple frames. In your case as I
>> understood it, the individual messages were smaller than this limit already.
>>
>> As suggested I posted the q on the Azure SB forum too to find if there are
>>> knobs in the SB configuration to make this un-ack buffer size bigger on
>>> the
>>> amqp ssl.
>>>
>>> Coming back on your suggestion about unsettled messages. Can u guide me
>>> what should be client side configuration (if any) to force server to keep
>>> sending without waiting for flow control ack from the client (number of
>>> unsettled messages ?). I would like server to stop on the link-credit
>>> running out, but not on the max_buffer of 16kb. Ideally i need is a
>>> behavior of atleast-once, but I am ready to sacrifice this requirement to
>>> get better perf.
>>>
>>
>> To request that message be sent settled, you can create your receiver
>> with the AtMostOnce option (imported from proton.reactor), e.g.:
>>
>> container.create_receiver(url, options=[AtMostOnce()])
>>
>> or
>>
>> container.create_receiver(conn, 'mysource', options=[AtMostOnce()])
>>
>> You could see if that has any effect.
>>
>>
>> ---------------------------------------------------------------------
>> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
>> For additional commands, e-mail: users-help@qpid.apache.org
>>
>>
>
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Gordon Sim <gs...@redhat.com>.
On 10/08/17 18:54, Pankaj Bhagra wrote:
> I wanted to experiment by disabling the flowControl. i did that by setting
> "prefetch"="None" , but that didn't get going. what would be way to disable
> the flow control to try out ?
You can't. Flow control is always in effect, all you can do is increase
or decrease the credit granted. You have already established that the
server is not waiting for credit. From a protocol perspective there is
nothing else I think you can try, I think you will need to see whether
the service bus forum can offer any insight into what is going on.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Pankaj Bhagra <pa...@gmail.com>.
My interest piqued by your pointer of forcing negotiation for getting
"settled" messages s.t. server can keep sending them without awaiting
client to acknowledge them. So i tried your recommendation of setting the
link option AtMostOnce. I went further and force the AtMostOnce to set the
"settled" for both send and receive message. However i still see server
doesn't release the next batch till it receive the acknowledgement from
client. this is puzzling, any other suggestion ?
I wanted to experiment by disabling the flowControl. i did that by setting
"prefetch"="None" , but that didn't get going. what would be way to disable
the flow control to try out ?
[0x24b0cd0]:0 -> @open(16)
[container-id="3feb8312-b228-4052-87ec-5ab12633be0c", hostname="
nebhubsb.servicebus.windows.net", channel-max=32767]
[0x24b0cd0]:0 -> @begin(17) [next-outgoing-id=0,
incoming-window=2147483647, outgoing-window=2147483647]
[0x24b0cd0]:0 -> @attach(18)
[name="3feb8312-b228-4052-87ec-5ab12633be0c-kukatopic/Subscriptions/kukasub",
handle=0, role=true, snd-settle-mode=1, rcv-settle-mode=1,
source=@source(40) [address="kukatopic/Subscriptions/kukasub", durable=0,
timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0,
dynamic=false], initial-delivery-count=0, max-message-size=0]
[0x24b0cd0]:0 -> @flow(19) [incoming-window=2147483647, next-outgoing-id=0,
outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=100,
drain=false]
[0x24b0cd0]: <- AMQP
[0x24b0cd0]:0 <- @open(16)
[container-id="2fdaeda28fb7483a9922790398ad1f0a_G20", max-frame-size=65536,
channel-max=4999, idle-time-out=240000]
[0x24b0cd0]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
incoming-window=5000, outgoing-window=2147483647, handle-max=255]
[0x24b0cd0]:0 <- @attach(18)
[name="3feb8312-b228-4052-87ec-5ab12633be0c-kukatopic/Subscriptions/kukasub",
handle=0, role=false, snd-settle-mode=1, source=@source(40)
[address="kukatopic/Subscriptions/kukasub", durable=0, timeout=0,
dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false],
initial-delivery-count=0, max-message-size=266240]
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1220)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=1, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1231)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=2, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1219)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=3, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1219)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=4, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1219)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=5, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1270)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=6, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1218)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=7, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1229)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=8, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (826)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=9, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1218)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=10, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1220)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=11, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1216)
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=12, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1216)
2017-08-10 01:49:00.417 pkt_seq = 1 remaining_in_batch = 12, 879
2017-08-10 01:49:00.417 pkt_seq = 2 remaining_in_batch = 11, 890
2017-08-10 01:49:00.417 pkt_seq = 3 remaining_in_batch = 10, 878
2017-08-10 01:49:00.418 pkt_seq = 4 remaining_in_batch = 9, 878
2017-08-10 01:49:00.419 pkt_seq = 5 remaining_in_batch = 8, 878
2017-08-10 01:49:00.419 pkt_seq = 6 remaining_in_batch = 7, 929
2017-08-10 01:49:00.419 pkt_seq = 7 remaining_in_batch = 6, 877
2017-08-10 01:49:00.420 pkt_seq = 8 remaining_in_batch = 5, 888
2017-08-10 01:49:00.420 pkt_seq = 9 remaining_in_batch = 4, 500
2017-08-10 01:49:00.421 pkt_seq = 10 remaining_in_batch = 3, 877
2017-08-10 01:49:00.421 pkt_seq = 11 remaining_in_batch = 2, 879
2017-08-10 01:49:00.421 pkt_seq = 12 remaining_in_batch = 1, 875
2017-08-10 01:49:00.422 pkt_seq = 13 remaining_in_batch = 0, 875
[0x24b0cd0]:0 -> @flow(19) [next-incoming-id=14,
incoming-window=2147483647, next-outgoing-id=0, outgoing-window=2147483647,
handle=0, delivery-count=13, link-credit=99, drain=false]
[0x24b0cd0]:0 <- @transfer(20) [handle=0, delivery-id=13, delivery-tag=b"",
message-format=0, settled=true, more=false, batchable=true] (1218)
and cycle continues ..
On Thu, Aug 10, 2017 at 3:01 AM, Gordon Sim <gs...@redhat.com> wrote:
> On 10/08/17 00:13, Pankaj Bhagra wrote:
>
>> Gordon,
>>
>> Further digging on network level sniffing shows that the bulk msg_size is
>> limited to = 16373 (16K). this observation is inline with previously
>> reported issue
>>
>
> What do you mean by msg_size here?
>
> http://grokbase.com/t/qpid/users/163z91rhdy/ssl-maximum-message-size
>>
>
> Interesting that the limit is the same, not sure what to make of that,
> perhaps its just a commonly used buffer size. The 'solution' in that issue
> was to break up large messages into multiple frames. In your case as I
> understood it, the individual messages were smaller than this limit already.
>
> As suggested I posted the q on the Azure SB forum too to find if there are
>> knobs in the SB configuration to make this un-ack buffer size bigger on
>> the
>> amqp ssl.
>>
>> Coming back on your suggestion about unsettled messages. Can u guide me
>> what should be client side configuration (if any) to force server to keep
>> sending without waiting for flow control ack from the client (number of
>> unsettled messages ?). I would like server to stop on the link-credit
>> running out, but not on the max_buffer of 16kb. Ideally i need is a
>> behavior of atleast-once, but I am ready to sacrifice this requirement to
>> get better perf.
>>
>
> To request that message be sent settled, you can create your receiver with
> the AtMostOnce option (imported from proton.reactor), e.g.:
>
> container.create_receiver(url, options=[AtMostOnce()])
>
> or
>
> container.create_receiver(conn, 'mysource', options=[AtMostOnce()])
>
> You could see if that has any effect.
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
>
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Gordon Sim <gs...@redhat.com>.
On 10/08/17 00:13, Pankaj Bhagra wrote:
> Gordon,
>
> Further digging on network level sniffing shows that the bulk msg_size is
> limited to = 16373 (16K). this observation is inline with previously
> reported issue
What do you mean by msg_size here?
> http://grokbase.com/t/qpid/users/163z91rhdy/ssl-maximum-message-size
Interesting that the limit is the same, not sure what to make of that,
perhaps its just a commonly used buffer size. The 'solution' in that
issue was to break up large messages into multiple frames. In your case
as I understood it, the individual messages were smaller than this limit
already.
> As suggested I posted the q on the Azure SB forum too to find if there are
> knobs in the SB configuration to make this un-ack buffer size bigger on the
> amqp ssl.
>
> Coming back on your suggestion about unsettled messages. Can u guide me
> what should be client side configuration (if any) to force server to keep
> sending without waiting for flow control ack from the client (number of
> unsettled messages ?). I would like server to stop on the link-credit
> running out, but not on the max_buffer of 16kb. Ideally i need is a
> behavior of atleast-once, but I am ready to sacrifice this requirement to
> get better perf.
To request that message be sent settled, you can create your receiver
with the AtMostOnce option (imported from proton.reactor), e.g.:
container.create_receiver(url, options=[AtMostOnce()])
or
container.create_receiver(conn, 'mysource', options=[AtMostOnce()])
You could see if that has any effect.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Pankaj Bhagra <pa...@gmail.com>.
Gordon,
Further digging on network level sniffing shows that the bulk msg_size is
limited to = 16373 (16K). this observation is inline with previously
reported issue
http://grokbase.com/t/qpid/users/163z91rhdy/ssl-maximum-message-size
As suggested I posted the q on the Azure SB forum too to find if there are
knobs in the SB configuration to make this un-ack buffer size bigger on the
amqp ssl.
Coming back on your suggestion about unsettled messages. Can u guide me
what should be client side configuration (if any) to force server to keep
sending without waiting for flow control ack from the client (number of
unsettled messages ?). I would like server to stop on the link-credit
running out, but not on the max_buffer of 16kb. Ideally i need is a
behavior of atleast-once, but I am ready to sacrifice this requirement to
get better perf.
currently client is requesting its recv-settle-mode to be "unsettled" and
server is sending its rev-settle-mode=settled. and my simplistic receiver
is initiating the messaging handler like
class Recv(MessagingHandler):
def __init__(self):
super(Recv, self).__init__(prefetch=100, auto_accept=True,
auto_settle=True)
[name="bc599ddc-74df-46b0-800c-401aed27f321-kukatopic/Subscriptions/kukasub",handle=0,
role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
[address="kukatopic/Subscriptions/kuka\
sub", durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0,
timeout=0, dynamic=false], initial-delivery-count=0, max-message-size=0]
[0xb58380]:0 -> @flow(19) [incoming-window=2147483647,
next-outgoing-id=0,outgoing-window=2147483647, handle=0, delivery-count=0,
link-credit=10000, drain=false]
[0xb58380]:0 <- @open(16)
[container-id="fa8f5d5577be485ebd7f5ebdbdfd9ca1_G13", max-frame-size=65536,
channel-max=4999, idle-time-out=240000]
[0xb58380]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
incoming-window=5000, outgoing-window=2147483647, handle-max=255]
[name="bc599ddc-74df-46b0-800c-401aed27f321-kukatopic/Subscriptions/kukasub",
handle=0, role=false, rcv-settle-mode=1, source=@source(40)
[address="kukatopic/Subscriptions/kukasub", durable=0, \
timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0,
dynamic=false], initial-delivery-count=0, max-message-size=266240]
On Wed, Aug 9, 2017 at 1:56 AM, Gordon Sim <gs...@redhat.com> wrote:
> On 09/08/17 08:22, Pankaj Bhagra wrote:
>
>> Thanks Gordon for looking into my query. It makes sense what u said,
>> however i am still searching for a reason of flow control and limited
>> batch
>> size.
>>
>> As per your suggestion i tried increasing the link-credit to 10k, 100k,
>> but
>> that doesn't change much. my understanding of prefetch was that its number
>> of packets not the number of bytes (i confirmed this by reducing the
>> prefetch to 2 and then i see only 1 pkt per bulk message (half of the
>> window size)).
>>
>> The size of the each pkt is roughly 900B, and as u can see that i am not
>> able to read more than 12 pkts per batch in the complete logs below. So
>> looking back yes the size of 12x900B is greater than 5KB, so the heading
>> may need correction - it looks like 2x of that which is 10kb.
>>
>> would appreciate if someone can suggest some more knobs i should play to
>> figure out where this limit of 10kb is coming from ?
>>
>
> My guess is that it is a service-bus choice (i.e. the buffer size it
> writes with). In itself that shouldn't require a roundtrip to get more. If
> that is happening it could conceivably be something to do with the number
> of unsettled messages?
>
> It may be worth asking about the issue on the service bus forums.
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
> For additional commands, e-mail: users-help@qpid.apache.org
>
>
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Gordon Sim <gs...@redhat.com>.
On 09/08/17 08:22, Pankaj Bhagra wrote:
> Thanks Gordon for looking into my query. It makes sense what u said,
> however i am still searching for a reason of flow control and limited batch
> size.
>
> As per your suggestion i tried increasing the link-credit to 10k, 100k, but
> that doesn't change much. my understanding of prefetch was that its number
> of packets not the number of bytes (i confirmed this by reducing the
> prefetch to 2 and then i see only 1 pkt per bulk message (half of the
> window size)).
>
> The size of the each pkt is roughly 900B, and as u can see that i am not
> able to read more than 12 pkts per batch in the complete logs below. So
> looking back yes the size of 12x900B is greater than 5KB, so the heading
> may need correction - it looks like 2x of that which is 10kb.
>
> would appreciate if someone can suggest some more knobs i should play to
> figure out where this limit of 10kb is coming from ?
My guess is that it is a service-bus choice (i.e. the buffer size it
writes with). In itself that shouldn't require a roundtrip to get more.
If that is happening it could conceivably be something to do with the
number of unsettled messages?
It may be worth asking about the issue on the service bus forums.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Pankaj Bhagra <pa...@gmail.com>.
Thanks Gordon for looking into my query. It makes sense what u said,
however i am still searching for a reason of flow control and limited batch
size.
As per your suggestion i tried increasing the link-credit to 10k, 100k, but
that doesn't change much. my understanding of prefetch was that its number
of packets not the number of bytes (i confirmed this by reducing the
prefetch to 2 and then i see only 1 pkt per bulk message (half of the
window size)).
The size of the each pkt is roughly 900B, and as u can see that i am not
able to read more than 12 pkts per batch in the complete logs below. So
looking back yes the size of 12x900B is greater than 5KB, so the heading
may need correction - it looks like 2x of that which is 10kb.
would appreciate if someone can suggest some more knobs i should play to
figure out where this limit of 10kb is coming from ? client advertised
incoming_window is incoming-window=2147483647 <(214)%20748-3647>
see the complete logs, as u can see the bulk size is limited to 12 pkts,
where the link credit remains at 9999, after every bulk.
[0xb58380]: -> SASL
[0xb58380]: <- SASL
[0xb58380]:0 <- @sasl-mechanisms(64)
[sasl-server-mechanisms=@PN_SYMBOL[:MSSBCBS, :PLAIN, :ANONYMOUS, :EXTERNAL]]
[0xb58380]:0 -> @sasl-init(65) [mechanism=:PLAIN,
initial-response=b"\x0xxxx"]
[0xb58380]:0 <- @sasl-outcome(68) [code=0, additional-data=b"Welcome!"]
[0xb58380]: -> AMQP
[0xb58380]:0 -> @open(16)
[container-id="bc599ddc-74df-46b0-800c-401aed27f321", hostname="
nebhubsb.servicebus.windows.net", channel-max=32767]
[0xb58380]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647,
outgoing-window=2147483647]
[0xb58380]:0 -> @attach(18)
[name="bc599ddc-74df-46b0-800c-401aed27f321-kukatopic/Subscriptions/kukasub",
handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0,
source=@source(40) [address="kukatopic/Subscriptions/kukasub", durable=0,
timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0,
dynamic=false], initial-delivery-count=0, max-message-size=0]
[0xb58380]:0 -> @flow(19) [incoming-window=2147483647, next-outgoing-id=0,
outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=10000,
drain=false]
[0xb58380]: <- AMQP
[0xb58380]:0 <- @open(16)
[container-id="fa8f5d5577be485ebd7f5ebdbdfd9ca1_G13", max-frame-size=65536,
channel-max=4999, idle-time-out=240000]
[0xb58380]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
incoming-window=5000, outgoing-window=2147483647, handle-max=255]
[0xb58380]:0 <- @attach(18)
[name="bc599ddc-74df-46b0-800c-401aed27f321-kukatopic/Subscriptions/kukasub",
handle=0, role=false, rcv-settle-mode=1, source=@source(40)
[address="kukatopic/Subscriptions/kukasub", durable=0, timeout=0,
dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false],
initial-delivery-count=0, max-message-size=266240]
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=0,
delivery-tag=b"\x06\xa8\xb3\xf9\x94\x1b\x09H\xa0\xc7\xf2\x11\xd7I\xa9\x12",
message-format=0, more=false, batchable=true] (1250) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xc7\x0a\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x15\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03o{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:29.4663961Z",
"iteration": 467375, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.35237932}, "A3": {"units": "Double",
"value": 97.599472}, "A2": {"units": "Double", "value": -88.2291565}, "A5":
{"units": "Double", "value": 80"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=1,
delivery-tag=b"P\xb1\x94N9\x18\x0bD\xb6\x00[cr#\x1d\xab", message-format=0,
more=false, batchable=true] (1245)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xcb\x04\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x16\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03j{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:30.4976526Z",
"iteration": 467376, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.28403}, "A3": {"units": "Double",
"value": 90.7003937}, "A2": {"units": "Double", "value": -89.3041382},
"A5": {"units": "Double", "value": 88.6"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=2,
delivery-tag=b"\x12.\x19\xb4\x910\x8dE\x8a:\xf5\xbb\x96C\x1b\xc5",
message-format=0, more=false, batchable=true] (1248) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xcf+\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x17\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03m{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:31.4820328Z",
"iteration": 467377, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -1.19551659}, "A3": {"units": "Double",
"value": 89.9831085}, "A2": {"units": "Double", "value": -89.9831161},
"A5": {"units": "Double", "value": 90."... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=3,
delivery-tag=b"\xd0C\xa4\xd9\xde\x9a\xa2E\xb4n>\xd6\x03=\x9dM",
message-format=0, more=false, batchable=true] (1253) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xd3\x13\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x18\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03r{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:32.4976359Z",
"iteration": 467378, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 92.8772888}, "A2": {"units": "Double", "value": -89.094696}, "A5":
{"units": "Double", "value": 8"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=4,
delivery-tag=b"r-\xa9{\xeb\xdd\xaaE\xb5$\xe1\xef\xa6\xf4\xaf\xae",
message-format=0, more=false, batchable=true] (1254) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xd7\x0b\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x19\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03s{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:33.4976551Z",
"iteration": 467379, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 103.376465}, "A2": {"units": "Double", "value": -86.0274429},
"A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=5,
delivery-tag=b"J@h8\x07\x9d\xf4C\x91j\x90\x96\xdd\x04\x9e\xc7",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xdb\x05\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1a\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:34.5132557Z",
"iteration": 467380, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 107.544}, "A2": {"units": "Double", "value": -83.1735153}, "A5":
{"units": "Double", "value": 65."... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=6,
delivery-tag=b"\x9bz\x89J\x90MSB\x8b*ZT\xd5\x89\x15\x95", message-format=0,
more=false, batchable=true] (1249)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xde\xf1\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1b\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03n{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:35.5290977Z",
"iteration": 467381, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 107.362862}, "A2": {"units": "Double", "value": -83.33}, "A5":
{"units": "Double", "value": 65.96"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=7,
delivery-tag=b"\x06\xbb\xaf\xdf\xe1^\xf5G\x9c\xf5e\xd1\xa7\xf6\xd5\xfb",
message-format=0, more=false, batchable=true] (1253) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xe3\x17\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1c\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03r{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:36.5758427Z",
"iteration": 467382, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 100.348694}, "A2": {"units": "Double", "value": -87.373642}, "A5":
{"units": "Double", "value": 7"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=8,
delivery-tag=b"\xa3\xc8\x93-\xfa\xa7IL\x93\xb4;\xaf\xc5\xb4\xc7\xa8",
message-format=0, more=false, batchable=true] (1254) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xe7\x0f\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1d\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03s{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:37.5225192Z",
"iteration": 467383, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.09980822}, "A3": {"units": "Double",
"value": 90.2022552}, "A2": {"units": "Double", "value": -89.3671265},
"A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=9,
delivery-tag=b"\x1d\x08\xf2\xe6\xb3\x1b\xa0F\xb0$p\xd2\xc9\xbe\xa5\x03",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xeb\x07\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1e\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:38.5225063Z",
"iteration": 467384, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 2.16081071}, "A3": {"units": "Double",
"value": 89.9449539}, "A2": {"units": "Double", "value": -89.9449844},
"A5": {"units": "Double", "value": 9"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=10,
delivery-tag=b"\xca\x0f\xc8S\x08UEB\x8fc\xa0c^\x95C[", message-format=0,
more=false, batchable=true] (1250)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xee\xfe\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1f\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03o{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:39.5381273Z",
"iteration": 467385, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.35237932}, "A3": {"units": "Double",
"value": 92.891922}, "A2": {"units": "Double", "value": -89.0930252}, "A5":
{"units": "Double", "value": 86"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=11,
delivery-tag=b"\xe2\xdf\xdd\xcc>\x93\xc3L\x83"o|\xb7`\x00\x16",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xf2\xf6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9
\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:40.5381136Z",
"iteration": 467386, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.35237932}, "A3": {"units": "Double",
"value": 93.7598724}, "A2": {"units": "Double", "value": -88.9818115},
"A5": {"units": "Double", "value": 85.2"... (truncated)
called from init
2017-08-09 06:35:07.092 1 11
2017-08-09 06:35:07.092 2 10
2017-08-09 06:35:07.093 3 9
2017-08-09 06:35:07.093 4 8
2017-08-09 06:35:07.093 5 7
2017-08-09 06:35:07.094 6 6
2017-08-09 06:35:07.094 7 5
2017-08-09 06:35:07.095 8 4
2017-08-09 06:35:07.095 9 3
2017-08-09 06:35:07.095 10 2
2017-08-09 06:35:07.096 11 1
2017-08-09 06:35:07.096 12 0
[0xb58380]:0 -> @flow(19) [next-incoming-id=13, incoming-window=2147483647,
next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=12,
link-credit=9999, drain=false]
[0xb58380]:0 -> @disposition(21) [role=true, first=0, last=11,
settled=true, state=@accepted(36) []]
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=12,
delivery-tag=b"b\xe9\xde\x8c\x84\x81\x02@\x8dj\x92+\x1f\x09\xc0\x87",
message-format=0, more=false, batchable=true] (856) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xf3\xf0\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9!\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xe0\x06\xa1\x1biothub-connection-device-id\xa1\x1aNebbiolo-00012-1.Discovery\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636373159014164350\x00Su\xb0\x00\x00\x01\xf4{"AssetId":
{"type": "FOGOS_DOCKER", "eid": "Nebbiolo-00012-1.Discovery"},
"AssetUpdateHdr": {"timestamp": "2017-08-07T23:40:42.986629-07:00",
"iteration": 41655, "update_type": "AssetAttributes"}, "AssetItems":
{"DiscoverdInfo": {"DiscoveredList": "['krc-32-1', 'krc-32-3', 'krc-32-4',
'krc-22-18']", "DiscoveredCount": 4, "WhiteList": "['192.168.32.1', '
192.168.32.0/8', '192.168.32.3', '192.168.32.4']", "RunningCount": 4,
"WindowsRebootCount": 2}}, "parentId": "88eeb6e55ae548"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=13,
delivery-tag=b"\xc29\xa2 \x90\xc9\x11E\xa7 y\x9f\x11\x09\x82\xaf",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xf7\x0d\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9"\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:41.5693763Z",
"iteration": 467387, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.22507381}, "A3": {"units": "Double",
"value": 90.4831543}, "A2": {"units": "Double", "value": -89.3285599},
"A5": {"units": "Double", "value": 88.8"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=14,
delivery-tag=b"\xbeC\xf6#\x04LjL\x83^qn\x16]\x9af", message-format=0,
more=false, batchable=true] (1246)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xfa\xf6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9#\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03k{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:42.569343Z", "iteration":
467388, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 0.531275868}, "A3": {"units": "Double",
"value": 89.9966736}, "A2": {"units": "Double", "value": -89.9966736},
"A5": {"units": "Double", "value": 90.0"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=15,
delivery-tag=b"\xf4_\xa7\xba\xc8H\x02I\x83\xdd\xfb\x80\x82\xa0s\x80",
message-format=0, more=false, batchable=true] (1259) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xfe\xde\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9$\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03x{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:43.5537905Z",
"iteration": 467389, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.84453963e-08}, "A3": {"units":
"Double", "value": 90.0001831}, "A2": {"units": "Double", "value":
-90.0001831}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=16,
delivery-tag=b"\xa1\xe0M[\xa4H\x1eJ\x8d\x02v\x02\xe4\x0c\x14\x03",
message-format=0, more=false, batchable=true] (1254) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x02\xd5\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9%\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03s{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:44.5850014Z",
"iteration": 467390, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.82398274e-08}, "A3": {"units":
"Double", "value": 90.222847}, "A2": {"units": "Double", "value":
-90.222847}, "A5": {"units": "Double", "value": 87"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=17,
delivery-tag=b"\xc9h|\x93\xb0\xe3\x98I\xb8\x18\xf64\x14\xd5\xbb\xf6",
message-format=0, more=false, batchable=true] (1257) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x06\xce\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9&\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03v{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:45.3687793Z",
"iteration": 467391, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.67124625e-08}, "A3": {"units":
"Double", "value": 91.8771896}, "A2": {"units": "Double", "value":
-91.8771896}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=18,
delivery-tag=b"Og\xdf\x07\x06\xa6\xf4@\xa2'\xb4\xfde\xd7\x13\xc6",
message-format=0, more=false, batchable=true] (1259) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x0a\xe6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9'\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03x{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:46.3844118Z",
"iteration": 467392, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.27457609e-08}, "A3": {"units":
"Double", "value": 96.1736755}, "A2": {"units": "Double", "value":
-96.1736755}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=19,
delivery-tag=b"\xb9\xc1\xa7za\xc76F\xb5i\x91\x83:\xce\xac\xaf",
message-format=0, more=false, batchable=true] (1260) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x0e\xce\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9(\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03y{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:47.4000408Z",
"iteration": 467393, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.65389352e-09}, "A3": {"units":
"Double", "value": 101.688866}, "A2": {"units": "Double", "value":
-101.688866}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=20,
delivery-tag=b"\xbe87Z\xf5\xe6\x80B\x82\x0e>\x14\x8fr\xa4\xc9",
message-format=0, more=false, batchable=true] (1257) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x12\xb7\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9)\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03v{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:48.4000176Z",
"iteration": 467394, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 2.82696688e-09}, "A3": {"units":
"Double", "value": 106.917091}, "A2": {"units": "Double", "value":
-106.917091}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=21,
delivery-tag=b"\x91\x0b\xc3\xe6\x86\xc1\x0aN\xbe\x83\xdfo,\x03b\xdf",
message-format=0, more=false, batchable=true] (856) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x13\xc0\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9*\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xe0\x06\xa1\x1biothub-connection-device-id\xa1\x1aNebbiolo-00012-1.Discovery\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636373159014164350\x00Su\xb0\x00\x00\x01\xf4{"AssetId":
{"type": "FOGOS_DOCKER", "eid": "Nebbiolo-00012-1.Discovery"},
"AssetUpdateHdr": {"timestamp": "2017-08-07T23:40:51.188902-07:00",
"iteration": 41656, "update_type": "AssetAttributes"}, "AssetItems":
{"DiscoverdInfo": {"DiscoveredList": "['krc-32-1', 'krc-32-3', 'krc-32-4',
'krc-22-18']", "DiscoveredCount": 4, "WhiteList": "['192.168.32.1', '
192.168.32.0/8', '192.168.32.3', '192.168.32.4']", "RunningCount": 4,
"WindowsRebootCount": 2}}, "parentId": "88eeb6e55ae548"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=22,
delivery-tag=b"f\x03R\xe8\x07\x0a\xf5O\xb2W\x1b\x7f\x8c\xe3O\xdc",
message-format=0, more=false, batchable=true] (1260) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x16\xae\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9+\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03y{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:49.4156473Z",
"iteration": 467395, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.40006631e-10}, "A3": {"units":
"Double", "value": 109.827438}, "A2": {"units": "Double", "value":
-109.827438}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=23,
delivery-tag=b"\x08\xb6\xeb\x14 i\x8aA\xa8\xab\xffS\xdd\xd7\x8b\x83",
message-format=0, more=false, batchable=true] (1240) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x1a\xa6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9,\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03e{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:50.446901Z", "iteration":
467396, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -2.46100844e-05}, "A3": {"units":
"Double", "value": 110.0}, "A2": {"units": "Double", "value": -110.0},
"A5": {"units": "Double", "value": -90.0}, "A"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=24,
delivery-tag=b"\xce]\x1fC\xe7\xa7XO\x80\x96/\x1c\x9az\x12\xc6",
message-format=0, more=false, batchable=true] (1242) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x1e\xcc\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9-\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03g{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:51.4468996Z",
"iteration": 467397, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -0.792964}, "A3": {"units": "Double",
"value": 109.94561}, "A2": {"units": "Double", "value": -109.923813}, "A5":
{"units": "Double", "value": -90.02"... (truncated)
2017-08-09 06:35:07.111 13 12
2017-08-09 06:35:07.111 14 11
2017-08-09 06:35:07.112 15 10
2017-08-09 06:35:07.112 16 9
2017-08-09 06:35:07.113 17 8
2017-08-09 06:35:07.113 18 7
2017-08-09 06:35:07.113 19 6
2017-08-09 06:35:07.114 20 5
2017-08-09 06:35:07.114 21 4
2017-08-09 06:35:07.115 22 3
2017-08-09 06:35:07.115 23 2
2017-08-09 06:35:07.115 24 1
2017-08-09 06:35:07.116 25 0
[0xb58380]:0 -> @flow(19) [next-incoming-id=26, incoming-window=2147483647,
next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=25,
link-credit=9999, drain=false]
[0xb58380]:0 -> @disposition(21) [role=true, first=12, last=24,
settled=true, state=@accepted(36) []]
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=25,
delivery-tag=b"\x98\x1e\xc8\xb6\xd3\xb4bK\x94\xa7\xf7\x9e\xf2\xe2\xeao",
message-format=0, more=false, batchable=true] (1250) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93"\xc4\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9.\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03o{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:52.4781421Z",
"iteration": 467398, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -4.55131578}, "A3": {"units": "Double",
"value": 105.856033}, "A2": {"units": "Double", "value": -104.539864},
"A5": {"units": "Double", "value": -91.31"... (truncated)
On Mon, Aug 7, 2017 at 6:05 PM, Pankaj Bhagra <pa...@gmail.com> wrote:
> I am trying to extract bulk messages from azure SB.
>
> As per their documentation the azure SDK doesn't support bulk read message
> and recommends using the native amqp for the Azure Service Bus. White
> trying to negotiate a session with the azure SB, i noticed that independent
> of what client is requesting, the SB dials down the incoming_window=5000.
> This limits a max of 5000B send per bulk read, thus my consumer runs dry
> till the RTT (which is large for inter cloud) to fetch a new packet.
>
> Is this a restriction of the azure SB or am i not setting any/some of the
> parameters correctly from the client side to achieve the negotiated window
> size > 5000B.
>
> I am using python proton MessagingHandler Class and clearly see that
> on_message is called for few pkts composing of buffer size ~5000B and then
> have to wait for the RTT delay to get the next batch.
>
> Any suggestion to work around this problem and get larger bulked message ?
> I can't reduce the RTT between the server and consumer. have some
> workaround for parallel consumers but would like to solve the bulk problem
> as that is most efficient way of achieving the high throughput.
>
> class Recv(MessagingHandler):
>
> def __init__(self):
>
> super(Recv, self).__init__(prefetch=100, auto_accept=True,
> auto_settle=True, peer_close_is_error=False)
>
>
> def on_start(self, event):
>
> conn = event.container.connect(connString)
>
> event.container.create_receiver(conn, subscription)
>
>
> def on_message(self, event):
>
> print(event.message.body)
>
> print datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S.%f')[:-3],
> self.count, event.receiver.queued
>
>
> [0xace380]: -> SASL
>
> [0xace380]: <- SASL
>
> [0xace380]:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@PN_SYMBOL[:MSSBCBS,
> :PLAIN, :ANONYMOUS, :EXTERNAL]]
>
> [0xace380]:0 -> @sasl-init(65) [mechanism=:PLAIN, initial-response=b"\
> x00iothubroutes_XXXXX\XXXXX="]
>
> [0xace380]:0 <- @sasl-outcome(68) [code=0, additional-data=b"Welcome!"]
>
> [0xace380]: -> AMQP
>
> [0xace380]:0 -> @open(16) [container-id="0ad171ca-cefa-4a27-a7dc-0520e5393fa5",
> hostname="nebhubsb.servicebus.windows.net", channel-max=32767]
>
> [0xace380]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647
> <(214)%20748-3647>, outgoing-window=2147483647 <(214)%20748-3647>]
>
> [0xace380]:0 -> @attach(18) [name="0ad171ca-cefa-4a27-
> a7dc-0520e5393fa5-kukatopic/Subscriptions/kukasub", handle=0, role=true,
> snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
> [address="kukatopic/Subscriptions/kukasub", durable=0, timeout=0,
> dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false],
> initial-delivery-count=0, max-message-size=0]
>
> [0xace380]:0 -> @flow(19) [incoming-window=2147483647 <(214)%20748-3647>,
> next-outgoing-id=0, outgoing-window=2147483647 <(214)%20748-3647>,
> handle=0, delivery-count=0, link-credit=100, drain=false]
>
> [0xace380]: <- AMQP
>
> [0xace380]:0 <- @open(16) [container-id="b970f07881334c658eb80ff336f2a683_G16",
> max-frame-size=65536, channel-max=4999, idle-time-out=240000]
>
> [0xace380]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
> incoming-window=5000, outgoing-window=2147483647 <(214)%20748-3647>,
> handle-max=255]
>
> [0xace380]:0 <- @attach(18) [name="0ad171ca-cefa-4a27-
> a7dc-0520e5393fa5-kukatopic/Subscriptions/kukasub", handle=0, role=false,
> rcv-settle-mode=1, source=@source(40) [address="topic/Subscriptions/sub",
> durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0,
> timeout=0, dynamic=false], initial-delivery-count=0,
> max-message-size=266240]
>
>
>
>
Re: proton server (azure SB) limit the incoming_window=5000
Posted by Pankaj Bhagra <pa...@gmail.com>.
Thanks Gordon for looking into my query. It makes sense what u said,
however i am still searching for a reason of flow control and limited batch
size.
As per your suggestion i tried increasing the link-credit to 10k, 100k, but
that doesn't change much. my understanding of prefetch was that its number
of packets not the number of bytes (i confirmed this by reducing the
prefetch to 2 and then i see only 1 pkt per bulk message (half of the
window size)).
The size of the each pkt is roughly 900B, and as u can see that i am not
able to read more than 12 pkts per batch in the complete logs below. So
looking back yes the size of 12x900B is greater than 5KB, so the heading
may need correction - it looks like 2x of that which is 10kb.
would appreciate if someone can suggest some more knobs i should play to
figure out where this limit of 10kb is coming from ? client advertised
incoming_window is incoming-window=2147483647 <(214)%20748-3647>
see the complete logs, as u can see the bulk size is limited to 12 pkts,
where the link credit remains at 9999, after every bulk.
[0xb58380]: -> SASL
[0xb58380]: <- SASL
[0xb58380]:0 <- @sasl-mechanisms(64)
[sasl-server-mechanisms=@PN_SYMBOL[:MSSBCBS, :PLAIN, :ANONYMOUS, :EXTERNAL]]
[0xb58380]:0 -> @sasl-init(65) [mechanism=:PLAIN,
initial-response=b"\x0xxxx"]
[0xb58380]:0 <- @sasl-outcome(68) [code=0, additional-data=b"Welcome!"]
[0xb58380]: -> AMQP
[0xb58380]:0 -> @open(16)
[container-id="bc599ddc-74df-46b0-800c-401aed27f321", hostname="
nebhubsb.servicebus.windows.net", channel-max=32767]
[0xb58380]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647,
outgoing-window=2147483647]
[0xb58380]:0 -> @attach(18)
[name="bc599ddc-74df-46b0-800c-401aed27f321-kukatopic/Subscriptions/kukasub",
handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0,
source=@source(40) [address="kukatopic/Subscriptions/kukasub", durable=0,
timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0,
dynamic=false], initial-delivery-count=0, max-message-size=0]
[0xb58380]:0 -> @flow(19) [incoming-window=2147483647, next-outgoing-id=0,
outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=10000,
drain=false]
[0xb58380]: <- AMQP
[0xb58380]:0 <- @open(16)
[container-id="fa8f5d5577be485ebd7f5ebdbdfd9ca1_G13", max-frame-size=65536,
channel-max=4999, idle-time-out=240000]
[0xb58380]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
incoming-window=5000, outgoing-window=2147483647, handle-max=255]
[0xb58380]:0 <- @attach(18)
[name="bc599ddc-74df-46b0-800c-401aed27f321-kukatopic/Subscriptions/kukasub",
handle=0, role=false, rcv-settle-mode=1, source=@source(40)
[address="kukatopic/Subscriptions/kukasub", durable=0, timeout=0,
dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false],
initial-delivery-count=0, max-message-size=266240]
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=0,
delivery-tag=b"\x06\xa8\xb3\xf9\x94\x1b\x09H\xa0\xc7\xf2\x11\xd7I\xa9\x12",
message-format=0, more=false, batchable=true] (1250) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xc7\x0a\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x15\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03o{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:29.4663961Z",
"iteration": 467375, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.35237932}, "A3": {"units": "Double",
"value": 97.599472}, "A2": {"units": "Double", "value": -88.2291565}, "A5":
{"units": "Double", "value": 80"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=1,
delivery-tag=b"P\xb1\x94N9\x18\x0bD\xb6\x00[cr#\x1d\xab", message-format=0,
more=false, batchable=true] (1245)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xcb\x04\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x16\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03j{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:30.4976526Z",
"iteration": 467376, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.28403}, "A3": {"units": "Double",
"value": 90.7003937}, "A2": {"units": "Double", "value": -89.3041382},
"A5": {"units": "Double", "value": 88.6"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=2,
delivery-tag=b"\x12.\x19\xb4\x910\x8dE\x8a:\xf5\xbb\x96C\x1b\xc5",
message-format=0, more=false, batchable=true] (1248) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xcf+\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x17\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03m{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:31.4820328Z",
"iteration": 467377, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -1.19551659}, "A3": {"units": "Double",
"value": 89.9831085}, "A2": {"units": "Double", "value": -89.9831161},
"A5": {"units": "Double", "value": 90."... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=3,
delivery-tag=b"\xd0C\xa4\xd9\xde\x9a\xa2E\xb4n>\xd6\x03=\x9dM",
message-format=0, more=false, batchable=true] (1253) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xd3\x13\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x18\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03r{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:32.4976359Z",
"iteration": 467378, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 92.8772888}, "A2": {"units": "Double", "value": -89.094696}, "A5":
{"units": "Double", "value": 8"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=4,
delivery-tag=b"r-\xa9{\xeb\xdd\xaaE\xb5$\xe1\xef\xa6\xf4\xaf\xae",
message-format=0, more=false, batchable=true] (1254) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xd7\x0b\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x19\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03s{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:33.4976551Z",
"iteration": 467379, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 103.376465}, "A2": {"units": "Double", "value": -86.0274429},
"A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=5,
delivery-tag=b"J@h8\x07\x9d\xf4C\x91j\x90\x96\xdd\x04\x9e\xc7",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xdb\x05\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1a\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:34.5132557Z",
"iteration": 467380, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 107.544}, "A2": {"units": "Double", "value": -83.1735153}, "A5":
{"units": "Double", "value": 65."... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=6,
delivery-tag=b"\x9bz\x89J\x90MSB\x8b*ZT\xd5\x89\x15\x95", message-format=0,
more=false, batchable=true] (1249)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xde\xf1\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1b\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03n{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:35.5290977Z",
"iteration": 467381, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 107.362862}, "A2": {"units": "Double", "value": -83.33}, "A5":
{"units": "Double", "value": 65.96"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=7,
delivery-tag=b"\x06\xbb\xaf\xdf\xe1^\xf5G\x9c\xf5e\xd1\xa7\xf6\xd5\xfb",
message-format=0, more=false, batchable=true] (1253) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xe3\x17\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1c\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03r{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:36.5758427Z",
"iteration": 467382, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.35237932}, "A3": {"units": "Double",
"value": 100.348694}, "A2": {"units": "Double", "value": -87.373642}, "A5":
{"units": "Double", "value": 7"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=8,
delivery-tag=b"\xa3\xc8\x93-\xfa\xa7IL\x93\xb4;\xaf\xc5\xb4\xc7\xa8",
message-format=0, more=false, batchable=true] (1254) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xe7\x0f\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1d\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03s{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:37.5225192Z",
"iteration": 467383, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -7.09980822}, "A3": {"units": "Double",
"value": 90.2022552}, "A2": {"units": "Double", "value": -89.3671265},
"A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=9,
delivery-tag=b"\x1d\x08\xf2\xe6\xb3\x1b\xa0F\xb0$p\xd2\xc9\xbe\xa5\x03",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xeb\x07\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1e\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:38.5225063Z",
"iteration": 467384, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 2.16081071}, "A3": {"units": "Double",
"value": 89.9449539}, "A2": {"units": "Double", "value": -89.9449844},
"A5": {"units": "Double", "value": 9"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=10,
delivery-tag=b"\xca\x0f\xc8S\x08UEB\x8fc\xa0c^\x95C[", message-format=0,
more=false, batchable=true] (1250)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xee\xfe\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9\x1f\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03o{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:39.5381273Z",
"iteration": 467385, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.35237932}, "A3": {"units": "Double",
"value": 92.891922}, "A2": {"units": "Double", "value": -89.0930252}, "A5":
{"units": "Double", "value": 86"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=11,
delivery-tag=b"\xe2\xdf\xdd\xcc>\x93\xc3L\x83"o|\xb7`\x00\x16",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xf2\xf6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9
\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:40.5381136Z",
"iteration": 467386, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.35237932}, "A3": {"units": "Double",
"value": 93.7598724}, "A2": {"units": "Double", "value": -88.9818115},
"A5": {"units": "Double", "value": 85.2"... (truncated)
called from init
2017-08-09 06:35:07.092 1 11
2017-08-09 06:35:07.092 2 10
2017-08-09 06:35:07.093 3 9
2017-08-09 06:35:07.093 4 8
2017-08-09 06:35:07.093 5 7
2017-08-09 06:35:07.094 6 6
2017-08-09 06:35:07.094 7 5
2017-08-09 06:35:07.095 8 4
2017-08-09 06:35:07.095 9 3
2017-08-09 06:35:07.095 10 2
2017-08-09 06:35:07.096 11 1
2017-08-09 06:35:07.096 12 0
[0xb58380]:0 -> @flow(19) [next-incoming-id=13, incoming-window=2147483647,
next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=12,
link-credit=9999, drain=false]
[0xb58380]:0 -> @disposition(21) [role=true, first=0, last=11,
settled=true, state=@accepted(36) []]
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=12,
delivery-tag=b"b\xe9\xde\x8c\x84\x81\x02@\x8dj\x92+\x1f\x09\xc0\x87",
message-format=0, more=false, batchable=true] (856) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xf3\xf0\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9!\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xe0\x06\xa1\x1biothub-connection-device-id\xa1\x1aNebbiolo-00012-1.Discovery\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636373159014164350\x00Su\xb0\x00\x00\x01\xf4{"AssetId":
{"type": "FOGOS_DOCKER", "eid": "Nebbiolo-00012-1.Discovery"},
"AssetUpdateHdr": {"timestamp": "2017-08-07T23:40:42.986629-07:00",
"iteration": 41655, "update_type": "AssetAttributes"}, "AssetItems":
{"DiscoverdInfo": {"DiscoveredList": "['krc-32-1', 'krc-32-3', 'krc-32-4',
'krc-22-18']", "DiscoveredCount": 4, "WhiteList": "['192.168.32.1', '
192.168.32.0/8', '192.168.32.3', '192.168.32.4']", "RunningCount": 4,
"WindowsRebootCount": 2}}, "parentId": "88eeb6e55ae548"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=13,
delivery-tag=b"\xc29\xa2 \x90\xc9\x11E\xa7 y\x9f\x11\x09\x82\xaf",
message-format=0, more=false, batchable=true] (1251) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xf7\x0d\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9"\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03p{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:41.5693763Z",
"iteration": 467387, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.22507381}, "A3": {"units": "Double",
"value": 90.4831543}, "A2": {"units": "Double", "value": -89.3285599},
"A5": {"units": "Double", "value": 88.8"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=14,
delivery-tag=b"\xbeC\xf6#\x04LjL\x83^qn\x16]\x9af", message-format=0,
more=false, batchable=true] (1246)
"\x00Sp\xc0\x0b\x05@@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xfa\xf6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9#\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03k{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:42.569343Z", "iteration":
467388, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 0.531275868}, "A3": {"units": "Double",
"value": 89.9966736}, "A2": {"units": "Double", "value": -89.9966736},
"A5": {"units": "Double", "value": 90.0"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=15,
delivery-tag=b"\xf4_\xa7\xba\xc8H\x02I\x83\xdd\xfb\x80\x82\xa0s\x80",
message-format=0, more=false, batchable=true] (1259) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x92\xfe\xde\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9$\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03x{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:43.5537905Z",
"iteration": 467389, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.84453963e-08}, "A3": {"units":
"Double", "value": 90.0001831}, "A2": {"units": "Double", "value":
-90.0001831}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=16,
delivery-tag=b"\xa1\xe0M[\xa4H\x1eJ\x8d\x02v\x02\xe4\x0c\x14\x03",
message-format=0, more=false, batchable=true] (1254) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x02\xd5\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9%\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03s{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:44.5850014Z",
"iteration": 467390, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.82398274e-08}, "A3": {"units":
"Double", "value": 90.222847}, "A2": {"units": "Double", "value":
-90.222847}, "A5": {"units": "Double", "value": 87"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=17,
delivery-tag=b"\xc9h|\x93\xb0\xe3\x98I\xb8\x18\xf64\x14\xd5\xbb\xf6",
message-format=0, more=false, batchable=true] (1257) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x06\xce\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9&\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03v{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:45.3687793Z",
"iteration": 467391, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.67124625e-08}, "A3": {"units":
"Double", "value": 91.8771896}, "A2": {"units": "Double", "value":
-91.8771896}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=18,
delivery-tag=b"Og\xdf\x07\x06\xa6\xf4@\xa2'\xb4\xfde\xd7\x13\xc6",
message-format=0, more=false, batchable=true] (1259) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x0a\xe6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9'\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03x{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:46.3844118Z",
"iteration": 467392, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.27457609e-08}, "A3": {"units":
"Double", "value": 96.1736755}, "A2": {"units": "Double", "value":
-96.1736755}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=19,
delivery-tag=b"\xb9\xc1\xa7za\xc76F\xb5i\x91\x83:\xce\xac\xaf",
message-format=0, more=false, batchable=true] (1260) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x0e\xce\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9(\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03y{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:47.4000408Z",
"iteration": 467393, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 7.65389352e-09}, "A3": {"units":
"Double", "value": 101.688866}, "A2": {"units": "Double", "value":
-101.688866}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=20,
delivery-tag=b"\xbe87Z\xf5\xe6\x80B\x82\x0e>\x14\x8fr\xa4\xc9",
message-format=0, more=false, batchable=true] (1257) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x12\xb7\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9)\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03v{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:48.4000176Z",
"iteration": 467394, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 2.82696688e-09}, "A3": {"units":
"Double", "value": 106.917091}, "A2": {"units": "Double", "value":
-106.917091}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=21,
delivery-tag=b"\x91\x0b\xc3\xe6\x86\xc1\x0aN\xbe\x83\xdfo,\x03b\xdf",
message-format=0, more=false, batchable=true] (856) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x13\xc0\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9*\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xe0\x06\xa1\x1biothub-connection-device-id\xa1\x1aNebbiolo-00012-1.Discovery\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636373159014164350\x00Su\xb0\x00\x00\x01\xf4{"AssetId":
{"type": "FOGOS_DOCKER", "eid": "Nebbiolo-00012-1.Discovery"},
"AssetUpdateHdr": {"timestamp": "2017-08-07T23:40:51.188902-07:00",
"iteration": 41656, "update_type": "AssetAttributes"}, "AssetItems":
{"DiscoverdInfo": {"DiscoveredList": "['krc-32-1', 'krc-32-3', 'krc-32-4',
'krc-22-18']", "DiscoveredCount": 4, "WhiteList": "['192.168.32.1', '
192.168.32.0/8', '192.168.32.3', '192.168.32.4']", "RunningCount": 4,
"WindowsRebootCount": 2}}, "parentId": "88eeb6e55ae548"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=22,
delivery-tag=b"f\x03R\xe8\x07\x0a\xf5O\xb2W\x1b\x7f\x8c\xe3O\xdc",
message-format=0, more=false, batchable=true] (1260) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x16\xae\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9+\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03y{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:49.4156473Z",
"iteration": 467395, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": 1.40006631e-10}, "A3": {"units":
"Double", "value": 109.827438}, "A2": {"units": "Double", "value":
-109.827438}, "A5": {"units": "Double", "value": "... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=23,
delivery-tag=b"\x08\xb6\xeb\x14 i\x8aA\xa8\xab\xffS\xdd\xd7\x8b\x83",
message-format=0, more=false, batchable=true] (1240) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x1a\xa6\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9,\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03e{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:50.446901Z", "iteration":
467396, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -2.46100844e-05}, "A3": {"units":
"Double", "value": 110.0}, "A2": {"units": "Double", "value": -110.0},
"A5": {"units": "Double", "value": -90.0}, "A"... (truncated)
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=24,
delivery-tag=b"\xce]\x1fC\xe7\xa7XO\x80\x96/\x1c\x9az\x12\xc6",
message-format=0, more=false, batchable=true] (1242) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93\x1e\xcc\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9-\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03g{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:51.4468996Z",
"iteration": 467397, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -0.792964}, "A3": {"units": "Double",
"value": 109.94561}, "A2": {"units": "Double", "value": -109.923813}, "A5":
{"units": "Double", "value": -90.02"... (truncated)
2017-08-09 06:35:07.111 13 12
2017-08-09 06:35:07.111 14 11
2017-08-09 06:35:07.112 15 10
2017-08-09 06:35:07.112 16 9
2017-08-09 06:35:07.113 17 8
2017-08-09 06:35:07.113 18 7
2017-08-09 06:35:07.113 19 6
2017-08-09 06:35:07.114 20 5
2017-08-09 06:35:07.114 21 4
2017-08-09 06:35:07.115 22 3
2017-08-09 06:35:07.115 23 2
2017-08-09 06:35:07.115 24 1
2017-08-09 06:35:07.116 25 0
[0xb58380]:0 -> @flow(19) [next-incoming-id=26, incoming-window=2147483647,
next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=25,
link-credit=9999, drain=false]
[0xb58380]:0 -> @disposition(21) [role=true, first=12, last=24,
settled=true, state=@accepted(36) []]
[0xb58380]:0 <- @transfer(20) [handle=0, delivery-id=25,
delivery-tag=b"\x98\x1e\xc8\xb6\xd3\xb4bK\x94\xa7\xf7\x9e\xf2\xe2\xeao",
message-format=0, more=false, batchable=true] (1250) "\x00Sp\xc0\x0b\x05@
@p\x05&\\x00@R\x02\x00Sq\xc1\x01\x00\x00Sr\xc1\\x06\xa3\x13x-opt-enqueued-time\x83\x00\x00\x01]\xc0\x93"\xc4\xa3\x15x-opt-sequence-number\x81\x00\x00\x00\x00\x009\xc9.\xa3\x12x-opt-locked-until\x83\x00\x00\x01]\xc5\xb4\xa5)\x00St\xc1\xef\x06\xa1\x1biothub-connection-device-id\xa1)S-1-5-21-1936340646-3222415949-3237289474\xa1\x1diothub-connection-auth-method\xa1K{"scope":"hub","type":"sas","issuer":"iothub","acceptingIpFilterRule":null}\xa1$iothub-connection-auth-generation-id\xa1\x12636327363635593852\x00Su\xb0\x00\x00\x03o{"AssetId":
{"type": "KR C", "eid": "S-1-5-21-1936340646-3222415949-3237289474"},
"AssetUpdateHdr": {"timestamp": "2017-08-08T06:40:52.4781421Z",
"iteration": 467398, "update_type": "AssetAttributes"}, "parentId":
"88eeb6e55ae548de97576e16d5289050", "AssetMonitoredItems": {"AXIS_ACT":
{"A1": {"units": "Double", "value": -4.55131578}, "A3": {"units": "Double",
"value": 105.856033}, "A2": {"units": "Double", "value": -104.539864},
"A5": {"units": "Double", "value": -91.31"... (truncated)
On Mon, Aug 7, 2017 at 6:05 PM, Pankaj Bhagra <pa...@gmail.com> wrote:
> I am trying to extract bulk messages from azure SB.
>
> As per their documentation the azure SDK doesn't support bulk read message
> and recommends using the native amqp for the Azure Service Bus. White
> trying to negotiate a session with the azure SB, i noticed that independent
> of what client is requesting, the SB dials down the incoming_window=5000.
> This limits a max of 5000B send per bulk read, thus my consumer runs dry
> till the RTT (which is large for inter cloud) to fetch a new packet.
>
> Is this a restriction of the azure SB or am i not setting any/some of the
> parameters correctly from the client side to achieve the negotiated window
> size > 5000B.
>
> I am using python proton MessagingHandler Class and clearly see that
> on_message is called for few pkts composing of buffer size ~5000B and then
> have to wait for the RTT delay to get the next batch.
>
> Any suggestion to work around this problem and get larger bulked message ?
> I can't reduce the RTT between the server and consumer. have some
> workaround for parallel consumers but would like to solve the bulk problem
> as that is most efficient way of achieving the high throughput.
>
> class Recv(MessagingHandler):
>
> def __init__(self):
>
> super(Recv, self).__init__(prefetch=100, auto_accept=True,
> auto_settle=True, peer_close_is_error=False)
>
>
> def on_start(self, event):
>
> conn = event.container.connect(connString)
>
> event.container.create_receiver(conn, subscription)
>
>
> def on_message(self, event):
>
> print(event.message.body)
>
> print datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S.%f')[:-3],
> self.count, event.receiver.queued
>
>
> [0xace380]: -> SASL
>
> [0xace380]: <- SASL
>
> [0xace380]:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@PN_SYMBOL[:MSSBCBS,
> :PLAIN, :ANONYMOUS, :EXTERNAL]]
>
> [0xace380]:0 -> @sasl-init(65) [mechanism=:PLAIN, initial-response=b"\
> x00iothubroutes_XXXXX\XXXXX="]
>
> [0xace380]:0 <- @sasl-outcome(68) [code=0, additional-data=b"Welcome!"]
>
> [0xace380]: -> AMQP
>
> [0xace380]:0 -> @open(16) [container-id="0ad171ca-cefa-4a27-a7dc-0520e5393fa5",
> hostname="nebhubsb.servicebus.windows.net", channel-max=32767]
>
> [0xace380]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647
> <(214)%20748-3647>, outgoing-window=2147483647 <(214)%20748-3647>]
>
> [0xace380]:0 -> @attach(18) [name="0ad171ca-cefa-4a27-
> a7dc-0520e5393fa5-kukatopic/Subscriptions/kukasub", handle=0, role=true,
> snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
> [address="kukatopic/Subscriptions/kukasub", durable=0, timeout=0,
> dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false],
> initial-delivery-count=0, max-message-size=0]
>
> [0xace380]:0 -> @flow(19) [incoming-window=2147483647 <(214)%20748-3647>,
> next-outgoing-id=0, outgoing-window=2147483647 <(214)%20748-3647>,
> handle=0, delivery-count=0, link-credit=100, drain=false]
>
> [0xace380]: <- AMQP
>
> [0xace380]:0 <- @open(16) [container-id="b970f07881334c658eb80ff336f2a683_G16",
> max-frame-size=65536, channel-max=4999, idle-time-out=240000]
>
> [0xace380]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
> incoming-window=5000, outgoing-window=2147483647 <(214)%20748-3647>,
> handle-max=255]
>
> [0xace380]:0 <- @attach(18) [name="0ad171ca-cefa-4a27-
> a7dc-0520e5393fa5-kukatopic/Subscriptions/kukasub", handle=0, role=false,
> rcv-settle-mode=1, source=@source(40) [address="topic/Subscriptions/sub",
> durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0,
> timeout=0, dynamic=false], initial-delivery-count=0,
> max-message-size=266240]
>
>
>
>