Function test_intstr_mapping

test.py:89–119

()

async def test_intstr_mapping():
    client = make_client()
    total_time = 0
    for _ in range(NUM_BENCHMARK_RUNS):
        start_time = time.time()

        res = await client.collect_arrow(
            QUERY,
            hypersync.StreamConfig(
                hex_output=HexOutput.PREFIXED,
                column_mapping=hypersync.ColumnMapping(
                    trace={
                        TraceField.TRANSACTION_POSITION: DataType.INT32,
                    },
                    transaction={
                        TransactionField.BLOCK_NUMBER: DataType.INT64,
                        TransactionField.VALUE: DataType.FLOAT32,
                    },
                    decoded_log={
                        "value": DataType.INTSTR,
                    },
                ),
                event_signature="Transfer(address indexed from, address indexed to, uint256 value)",
            ),
        )

        # print(res.data.decoded_logs.column("value"))

        execution_time = (time.time() - start_time) * 1000
        total_time += execution_time
    print(f"intstr_mapping time: {format(execution_time, '.9f')}ms")


async def test_create_parquet_folder():