Python 雅典娜查询

Question

一秒钟内可以执行多少个查询。我正在使用python pyathena库。

athena_cursor = connect(aws_access_key_id=CREDENTIALS_DICTIONARY['AWS_ACCESS_KEY'],
                        aws_secret_access_key=CREDENTIALS_DICTIONARY['AWS_SECRET_ACCESS_KEY'],
                        s3_staging_dir=CREDENTIALS_DICTIONARY['S3_STAGING_DIR'],
                        region_name=CREDENTIALS_DICTIONARY['REGION_NAME'],
                        cursor_class=AsyncCursor).cursor()

query_id, future = athena_cursor.execute(query, query_dict)
result_set = future.result()
logging.warning("[{}] [ATHENA] [QUERY] [END] [{}]".format(datetime.now(), query))
results = result_set.fetchall()

Answer 1

根据 service limits 上的 AWS Athena 文档

您每秒最多可以拨打 20 个StartQueryExecution 电话。另外，如果4秒内不调用该接口，您的账户会累积最多80次调用的突增容量。在这种情况下，您的应用程序可以在突发模式下对该 API 进行多达 80 次调用。

尽管您可以联系 AWS Support 请求提高限制。