提供的功能
- 高频率发送交易并记录结果
- 提供http API服务
- 生成报告并定期提交给 Slack
- 主动检查确认损失并向 Slack 发送警报
- slack alert 垃圾邮件过滤器
Solana 项目演示了Solana 区块链的实时每秒交易量 (TPS)仪表板。该项目利用了以下技术:
Rust Backend :从Solana 区块链获取实时数据并将其存储在InfluxDB中以进行时间序列数据管理。
InfluxDB:用于存储 Solana 交易数据的高性能时间序列数据库。
Streamlit:一个基于 Python 的框架,用于构建TPS和其他关键指标的交互式可视化。
该仪表板提供了对 Solana 区块链性能的实时洞察,帮助用户跟踪和分析交易吞吐量和其他相关指标。它是集成Rust、Python和InfluxDB以构建高效实时数据管道和可视化工具的一个示例
当使用Solana部署私链或者侧链时,需要自定义链的手续费价格
先说如何配置
拿multinode-demo/setup.sh举例
在文件尾部添加 --target-lamports-per-signature
...
default_arg --target-lamports-per-signature 10
$solana_genesis "${args[@]}"
sdk/program/src/fee_calculator.rs
pub fn new_derived(
base_fee_rate_governor: &FeeRateGovernor,
latest_signatures_per_slot: u64,
) -> Self {
let mut me = base_fee_rate_governor.clone();
if me.target_signatures_per_slot > 0 { // 当配置target_signatures_per_slot时
// lamports_per_signature can range from 50% to 1000% of
// target_lamports_per_signature
me.min_lamports_per_signature = std::cmp::max(1, me.target_lamports_per_signature / 2);
me.max_lamports_per_signature = me.target_lamports_per_signature * 10;
// What the cluster should charge at `latest_signatures_per_slot`
let desired_lamports_per_signature =
me.max_lamports_per_signature
.min(me.min_lamports_per_signature.max(
me.target_lamports_per_signature
* std::cmp::min(latest_signatures_per_slot, std::u32::MAX as u64)
/ me.target_signatures_per_slot,
));
trace!(
"desired_lamports_per_signature: {}",
desired_lamports_per_signature
);
let gap = desired_lamports_per_signature as i64
- base_fee_rate_governor.lamports_per_signature as i64;
if gap == 0 {
me.lamports_per_signature = desired_lamports_per_signature;
} else {
// Adjust fee by 5% of target_lamports_per_signature to produce a smooth
// increase/decrease in fees over time.
let gap_adjust =
std::cmp::max(1, me.target_lamports_per_signature / 20) as i64 * gap.signum();
trace!(
"lamports_per_signature gap is {}, adjusting by {}",
gap,
gap_adjust
);
me.lamports_per_signature =
me.max_lamports_per_signature
.min(me.min_lamports_per_signature.max(
(base_fee_rate_governor.lamports_per_signature as i64 + gap_adjust)
as u64,
));
}
} else { // 当没有设置target_signatures_per_slot时,链采用固定价格
me.lamports_per_signature = base_fee_rate_governor.target_lamports_per_signature;
me.min_lamports_per_signature = me.target_lamports_per_signature;
me.max_lamports_per_signature = me.target_lamports_per_signature;
}
debug!(
"new_derived(): lamports_per_signature: {}",
me.lamports_per_signature
);
me
}
fn main() {
let latest_signatures_per_slot = 1;
let target_signatures_per_slot = 10;
let target_lamports_per_signature = 100;
let min_lamports_per_signature = std::cmp::max(1, target_lamports_per_signature / 2);
let max_lamports_per_signature = target_lamports_per_signature * 10;
let desired_lamports_per_signature =
max_lamports_per_signature
.min(min_lamports_per_signature.max(
target_lamports_per_signature
* std::cmp::min(latest_signatures_per_slot, std::u32::MAX as u64)
/ target_signatures_per_slot,
));
println!("{}", desired_lamports_per_signature);
}