fix: updated event size limit in request (#41)

* Updated event size limit

* Updated batch size limit

* fix: updated test to reflect the updated batch limit

rudderstack/analytics/consumer.py

@@ -8,11 +8,11 @@
 
 from queue import Empty
 
-MAX_MSG_SIZE = 32 << 10
+MAX_MSG_SIZE = 4 << 10 << 10 ## 4 mb
 
 # Our servers only accept batches less than 500KB. Here limit is set slightly
 # lower to leave space for extra data that will be added later, eg. "sentAt".
-BATCH_SIZE_LIMIT = 475000
+BATCH_SIZE_LIMIT = 4 << 10 << 10 ## 4 mb
 
 
 class Consumer(Thread):
@@ -94,7 +94,7 @@ def next(self):
  item, cls=DatetimeSerializer).encode())
  if item_size > MAX_MSG_SIZE:
  self.log.error(
- 'Item exceeds 32kb limit, dropping. (%s)', str(item))
+ 'Item exceeds 4mb limit, dropping. (%s)', str(item))
  continue
  items.append(item)
  total_size += item_size

rudderstack/analytics/test/test_consumer.py

@@ -196,7 +196,7 @@ def test_max_batch_size(self):
  }
  msg_size = len(json.dumps(track).encode())
  # number of messages in a maximum-size batch
- n_msgs = int(475000 / msg_size)
+ n_msgs = int((4 << 10 << 10) / msg_size)
 
  def mock_post_fn(_, data, **kwargs):
  res = mock.Mock()