import { SignalMarket } from '@signal-market/sdk';
const client = new SignalMarket({
apiKey: process.env.SIGNAL_API_KEY,
baseUrl: 'https://api.signal.market'
});
// 获取事件列表
const events = await client.events.list({
limit: 10,
stage: 'accelerating,peak',
sortBy: 'probability',
sortOrder: 'desc'
});
console.log('发现事件:', events.events.length);
// 获取特定事件概率
const probability = await client.events.getProbability('evt_001');
console.log('当前概率:', probability.current);
console.log('7天预测:', probability.P_7d);
// 获取用户透镜简报
const brief = await client.lenses.getBrief('lens_a_stock');
console.log('关注主题:', brief.topics_watched);
console.log('机会:', brief.top_opportunities);
import { SignalMarket, EventStage } from '@signal-market/sdk';
const client = new SignalMarket({ apiKey: 'your_key' });
// 使用流式订阅实时更新
const stream = client.events.subscribe({
stage: [EventStage.ACCELERATING, EventStage.PEAK]
});
stream.on('event', (event) => {
console.log('新事件:', event.title);
// 自动处理
});
// 创建自定义监控
const watch = await client.watch.create({
event_ids: ['evt_001', 'evt_002', 'evt_003'],
notify_email: 'alert@example.com',
webhook_url: 'https://yourapp.com/webhook'
});
console.log('监控ID:', watch.watch_id);
// 批量查询
const results = await Promise.all([
client.events.getProbability('evt_001'),
client.events.getProbability('evt_002'),
client.events.getProbability('evt_003')
]);
// 处理结果
results.forEach(r => {
console.log(`${r.topic}: ${r.current * 100}%`);
});