Сообщения не отображаются в SQS - PullRequest
Новая
       29

Сообщения не отображаются в SQS

0 голосов
/ 31 января 2020

У меня есть следующий код в лямбда-выражении: 

  entries = [
        {
            "Id": str(index),
            "MessageAttributes": {},
            "MessageBody": json.dumps(
                to_format(record=record, id_names=IDENTIFIERS, attr_names=ATTRIBUTES, source_names=SOURCE_METADATA)
            ),
            "MessageDeduplicationId": record["message_composite_key"],
            "MessageGroupId": sqs_group_id
        } for index, record in enumerate(records)
    ]
    logger.info(f"{len(entries)} batch entries built")
    queue_url = environ["SQS_QUEUE_URL"]
    try:

        # iterate over entries in batches of 10
        for batch in [entries[index:index + sqs_batch_limit] for index in range(0, len(entries), sqs_batch_limit)]:
            logger.info(f"Sending batch of {len(batch)} records to sqs...")
            sqs.send_message_batch(
                QueueUrl=queue_url,
                Entries=batch
            )
            logger.info("**Sent batch of records to sqs successful**")

, и кажется, что он выдает ошибку из-за этого сообщения: 

 'InvalidParameterValue', 'Message': 'The request include parameter that is not valid for this queue type'

Я не могу найти документацию для htis где угодно. Есть идеи, что такое Гионг?

...