AWS Lambda中结合Azure Blob时EventHubConsumerClient的subscribe方法失效

我使用Node.js的EventHubConsumerClient读取第三方账户托管的EventHub事件，同时用自身Azure账户下的Blob存储容器维护已读取事件的检查点，并将Blob存储客户端作为参数传入EventHubConsumerClient。

本地运行时，应用可成功读取EventHub事件并使用Blob存储进行检查点记录，但部署到AWS Lambda后，调用consumer client的subscribe方法时出现错误：

Method get TypedArray.prototype.length called on incompatible receiver [object Object]

我已通过日志确认AWS可成功连接Blob存储，但未找到相关EventHub文档定位根因，也不清楚调试方向。请问是否有人遇到过该问题？

相关代码 #

创建Blob检查点存储的代码 #

const createCheckpointStore = async (
  blobStorageUrl: string,
  accountName: string,
  accountKey: string
): Promise<BlobCheckpointStore> => {
  const credentials = new StorageSharedKeyCredential(accountName, accountKey)
  const blobServiceClient = new BlobServiceClient(blobStorageUrl, credentials)

  const blobContainerClient = blobServiceClient.getContainerClient(
    'event-hub-checkpoint'
  )

  const iter = blobContainerClient.listBlobsFlat()
  for await (const item of iter) {
    console.log(`\tBlobItem: name - ${item.name}`)
    const blockBlobClient = blobContainerClient.getBlockBlobClient(item.name)
    const meta = (await blockBlobClient.getProperties()).metadata
    console.log(meta)
  }

  return new BlobCheckpointStore(blobContainerClient)
}

创建EventHub消费者客户端的代码 #

const createEventHubConsumerClient = async () => {
  try {
    const accountName = await getSecretFromEnvVariable(
      'BLOB_STORAGE_ACCOUNT_NAME'
    )
    const accountKey = await getSecretFromEnvVariable(
      'BLOB_STORAGE_ACCOUNT_KEY'
    )

    const checkpointStore = await createCheckpointStore(
      getEnvironmentVariable('BLOB_STORAGE_URL'),
      accountName,
      accountKey
    )
    const consumerGroup = '$Default'
    const eventHubConnectionString = getEnvironmentVariable(
      'EXPORT_EVENT_HUB_CONNECTION_STRING'
    )
    const eventHubName = 'export'

    return new EventHubConsumerClient(
      consumerGroup,
      eventHubConnectionString,
      eventHubName,
      checkpointStore
    )
  } catch (error) {
    console.error('error creating eventhub consumer client', error)
    throw error
  }
}

读取事件的方法代码 #

const getEvents = async () => {
  const consumerClient = await createEventHubConsumerClient()
  try {
    await new Promise<void>((resolve, reject) => {
      const subscription: Subscription = consumerClient.subscribe(
        {
          processEvents: async (events, context) => {
            console.log('received events', events)
            await asyncForEach(events, async (event: ReceivedEventData) => {
              const processedEntities = extractEntitiesFromEventHubEvent(event)
              await asyncForEach(
                processedEntities,
                async (entity: any) => {
                  try {
                    console.log(entity)
                  } catch (err) {
                    throw new Error(err)
                  }
                }
              )
              await context.updateCheckpoint(events[events.length - 1])
            })
          },
          processError: async err => {
            console.error('error encountered', err)
            await subscription.close()
            await consumerClient.close()
            console.error('error processing events', err)
            reject(new Error('error processing events'))
          },
        },
        {
          startPosition: earliestEventPosition,
          maxBatchSize: 100,
          maxWaitTimeInSeconds: 5,
        }
      )
    })
  } catch (err) {
    console.error('error encountered', err)
    throw new Error(err)
  }
}

解决方案 #

这个错误通常和AWS Lambda的Node.js运行时环境与Azure SDK依赖的TypedArray兼容性有关，以下是几个可行的调试和解决方向：

• 对齐Node.js版本：确保AWS Lambda使用的Node.js版本和本地开发环境完全一致。Azure SDK部分依赖对Node.js版本兼容性敏感，v16.x和v18.x在TypedArray处理上可能存在差异，优先选择本地验证通过的版本。
• 优化打包配置：如果用Webpack或ESBuild打包，尝试禁用tree-shaking功能，避免误删SDK核心代码；排查是否有自定义polyfill覆盖了原生TypedArray的length getter方法。
• 简化检查点初始化：移除创建BlobCheckpointStore前遍历Blob列表的调试代码，Lambda环境下的异步迭代可能引发兼容性问题，简化后的初始化代码如下：

const createCheckpointStore = async (
  blobStorageUrl: string,
  accountName: string,
  accountKey: string
): Promise<BlobCheckpointStore> => {
  const credentials = new StorageSharedKeyCredential(accountName, accountKey)
  const blobServiceClient = new BlobServiceClient(blobStorageUrl, credentials)
  const blobContainerClient = blobServiceClient.getContainerClient('event-hub-checkpoint')
  return new BlobCheckpointStore(blobContainerClient)
}

• 升级Azure SDK：将@azure/event-hubs和@azure/storage-blob升级到最新稳定版，这类环境兼容性问题通常会在后续版本中修复。
• 调试全局对象：在Lambda初始化阶段添加日志，打印TypedArray.prototype.length的属性描述符，确认是否被篡改：

console.log('TypedArray.prototype.length descriptor:', Object.getOwnPropertyDescriptor(TypedArray.prototype, 'length'))

内容的提问来源于stack exchange，提问作者RMMD12